0gam

https://stackoverflow.com/questions/45200585/using-kafka-connect-howto-commit-offsets-as-soon-as-a-put-is-completed-in-si Using Kafka Connect HOWTO "commit offsets" as soon as a "put" is completed in SinkTask I am using Kafka Connect to get messages from a Kafka Broker (v0.10.2) and then sync it to a downstream service. Currently, I have code in SinkTask#put that will process the SinkRecord & th..

import java.util.Arrays; import java.util.Properties; import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.clients.consumer.ConsumerRecords; import org.apache.kafka.clients.consumer.KafkaConsumer; public class ConsumerSample { public static void main(String[] args) { Properties props = new Properties(); props.put("bootstrap.servers", "203.251.177.28:9092"); props.put(..

package kafka.book.producer; import java.util.Properties; import org.apache.kafka.clients.producer.KafkaProducer; import org.apache.kafka.clients.producer.Producer; import org.apache.kafka.clients.producer.ProducerRecord; import org.apache.log4j.BasicConfigurator; /** * Hello world! * */ public class KafkaClientsProducerSample { public static void main(String[] args) { BasicConfigurator.configur..