search

mguenther / kafka-sampler

Showcases how to build Java applications using Apache Kafka and Kafka Streams
1 stars 0 forks source link

Port the existing Scala-based Kafka adapter to Java #3

Closed mguenther closed 7 years ago

mguenther commented 7 years ago

The kafka-scala-examples repository features a Kafka adapter that we should be able to use as a base for the sampler as well. Port the existing code to Java and migrate it to the Kafka client API in 0.10.1.1.

mguenther commented 7 years ago

This includes the codec abstraction (incl. encoder and decoder traits), the producer abstraction (not based on a Runnable, but a POJO) incl. ProducerConfig and the consumer abstraction (based on a Runnable or a scheduled job - we use Spring after all) incl. ConsumerConfig.

We could extend the Kafka adapter to use a functional interface called MessageProcessor for message processing as part of the consumer.

mguenther commented 7 years ago

Merged into development.