Hi, 1. What is log.message.format.version in Kafka 2. What is the use of log.message.format.version in Kafka 3.What could be the version of log.message.format Thanks, Nilesh ... View more

Team, I am receiving following an error while executing kafka mirror-maker command. Kerberos is configured on source and target cluster. kafka@hdpensrv$ /usr/hdp/current/kafka-broker/bin/kafka-mirror-maker.sh --consumer.config /tmp/sourceClusterConsumer.properties --producer.config /tmp/targetClusterProducer.properties --whitelist="topic_test" [2018-01-16 06:21:45,493] ERROR Exception when starting mirror maker. (kafka.tools.MirrorMaker$) org.apache.kafka.common.KafkaException: Failed to construct kafka producer at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:335) at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:188) at kafka.tools.MirrorMaker$MirrorMakerProducer.<init>(MirrorMaker.scala:626) at kafka.tools.MirrorMaker$.main(MirrorMaker.scala:213) at kafka.tools.MirrorMaker.main(MirrorMaker.scala) Caused by: org.apache.kafka.common.KafkaException: javax.security.auth.login.LoginException: Could not login: the client is being asked for a password, but the Kafka client code does not currently support obtaining a password from the user. not available to garner authentication information from the user at org.apache.kafka.common.network.SaslChannelBuilder.configure(SaslChannelBuilder.java:86) at org.apache.kafka.common.network.ChannelBuilders.create(ChannelBuilders.java:71) at org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:83) at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:277) ... 4 more ... View more

Hi, Is there any command to check Kafka version. Thank you. ... View more

Team, What will be happened if we ingest same data, in particular, Kafka topic again? Will it overwrite the data or will make another copy of data or it will just ignore and notify. ... View more