Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- Properties props = new Properties();
- props.put("bootstrap.servers", "host:9092");
- props.put("group.id", "test1");
- props.put("enable.auto.commit", "true");
- props.put("auto.commit.interval.ms", "1000");
- props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
- props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
- KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
- consumer.assign(Arrays.asList(new TopicPartition("chentong",0)));
- consumer.seek(new TopicPartition("chentong",0),121);
- for (;;) {
- ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
- for (ConsumerRecord<String, String> record : records) {
- System.out.printf("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value());
- }
- }
Add Comment
Please, Sign In to add comment