bin/kafka-topics.sh --zookeeper localhost:2181 --list
bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic mytopic
bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic mytopic --config retention.ms=1000
... wait a minute ...
start string producer with below command | |
kafka-console-producer.bat \ --broker-list broker-host:9091 --topic test --property "parse.key=true" --property "key.separator=:" | |
It will start producer and we can type message as below (key:value) | |
1:{ "PROGRAM_NAME": "NDTV", "ORIGINATOR": "JADE_FEVER", "channel": "CTV Drama+","weekday": "Monday", "DATE": "9/28/2018", "START_TIME": "17:30:00"} |
package com.operative.pipelinetracker.controller; | |
import java.util.HashMap; | |
import java.util.Map; | |
import java.util.Properties; | |
import org.apache.kafka.clients.consumer.KafkaConsumer; | |
import org.apache.kafka.clients.consumer.OffsetAndMetadata; | |
import org.apache.kafka.common.TopicPartition; | |
import org.apache.kafka.common.serialization.StringDeserializer; |
bin/kafka-topics.sh --zookeeper localhost:2181 --list
bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic mytopic
bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic mytopic --config retention.ms=1000
... wait a minute ...