Gopal S Akshintala
03/25/2020, 2:46 PMGregor Zeitlinger
04/20/2020, 7:11 AMAdabe Echaim
04/21/2020, 9:04 AMcrummy
04/21/2020, 9:06 AMjean-paul
04/26/2020, 9:00 AMspring webflux
with `reactor`… I would want to give a try to coroutines
instead but I ask myself if it would support all reactive stream
promises like back-pressure
. I would want my workflow unchanged: reactive streams in my services and reactive drivers for db’s I/O & ... should not be affected negatively! Is it possible? What I can win from this move? Thxkenkyee
04/26/2020, 11:15 AMHernan Ojeda
04/26/2020, 2:55 PMPypdeveloper
04/26/2020, 3:11 PMMike Conley
05/09/2020, 1:41 PMimport org.jdbi.v3.core.Jdbi
import org.jdbi.v3.sqlobject.statement.SqlQuery
import java.time.Duration
import javax.inject.Inject
class StupidDAO @Inject constructor(jdbi: Jdbi) : StupidSql by jdbi.onDemand(StupidSql::class.java) {
companion object {
@JvmStatic
fun main(args: Array<String>) {
val jdbi = DatabaseTestBase.jdbi // Connects to my postgresql test database.
val stupidDAO = StupidDAO(jdbi)
println(stupidDAO.doIt())
}
}
}
private interface StupidSql {
@SqlQuery("""
SELECT 'a' as id,
interval '1 hour' as value
""")
fun doIt(): List<StupidThing<Duration>>
}
data class StupidThing<T>(
val id: String,
val value: T
)
blows up withJoan Sala
05/12/2020, 8:10 PMAnaniya
05/15/2020, 7:50 AMMgkaki
06/05/2020, 12:59 PMTiagoeiras
06/10/2020, 12:45 PMleftTable.join(rightTable, myleftObject::getIdRight, LeftRightJoiner())
the error is :
None of the following functions can be called with the arguments supplied.
join(KTable<TypeVariable(KO)!, TypeVariable(VO)!>!, ((t: myleftObject!) → TypeVariable(KO)!)!, ((value1: myleftObject!, value2: TypeVariable(VO)!) → TypeVariable(VR)!)!) where VR = TypeVariable(VR), KO = TypeVariable(KO), VO = TypeVariable(VO) for fun <VR : Any!, KO : Any!, VO : Any!> join(other: KTable<KO!, VO!>!, foreignKeyExtractor: ((t: myleftObject!) → KO!)!, joiner: ((value1: myleftObject!, value2: VO!) → VR!)!): KTable<String!, VR!>! defined in org.apache.kafka.streams.kstream.KTable
I have taken this from
https://kafka-tutorials.confluent.io/foreign-key-joins/kstreams.html but this is in java language
Can somebody help me with this ?Remon Shehata
06/13/2020, 8:59 PMBrian Dilley
06/13/2020, 9:48 PMBrian Dilley
06/13/2020, 9:48 PMBrian Dilley
06/13/2020, 9:49 PMBrian Dilley
06/13/2020, 9:51 PMBrian Dilley
06/13/2020, 9:52 PMparth
06/18/2020, 7:45 PMKepha
07/08/2020, 2:40 AMJason5lee
07/25/2020, 4:12 AMJu
07/25/2020, 12:19 PMGopal Kalyanaraman
08/04/2020, 1:39 PMGopal Kalyanaraman
08/04/2020, 1:40 PM<plugin>
<groupId>org.jetbrains.kotlin</groupId>
<artifactId>kotlin-maven-plugin</artifactId>
<version>1.3.72</version>
<configuration>
<args>
<arg>-Xjsr305=strict</arg>
</args>
<compilerPlugins>
<plugin>spring</plugin>
</compilerPlugins>
<jvmTarget>11</jvmTarget>
</configuration>
<executions>
<execution>
<id>compile</id>
<phase>compile</phase>
<goals> <goal> compile </goal> </goals>
</execution>
<execution>
<id>test-compile</id>
<goals> <goal> test-compile </goal> </goals>
</execution>
</executions>
<dependencies>
<dependency>
<groupId>org.jetbrains.kotlin</groupId>
<artifactId>kotlin-maven-allopen</artifactId>
<version>${kotlin.version}</version>
</dependency>
<dependency>
<groupId>com.adobe.ams.ifttt</groupId>
<artifactId>commons</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>
</dependencies>
</plugin>
Gopal Kalyanaraman
08/04/2020, 1:40 PMxii
08/20/2020, 11:42 PMAyodele
08/29/2020, 9:11 AMHelio
08/31/2020, 11:02 PMGopal Kalyanaraman
09/03/2020, 9:41 AM