Member since
04-04-2018
80
Posts
32
Kudos Received
1
Solution
My Accepted Solutions
Title | Views | Posted |
---|---|---|
8147 | 10-28-2017 05:13 AM |
04-02-2018
06:54 PM
@Geoffrey Shelton Okot Thank you for your reply. I have some following queries, 1. What is inter.broker.protocol.version and what it does. 2. How log.message.format and inter.broker.protocol relate each other. 3. Could you please explain in detail the use of log.message.format.version. 4. When and on what basis need to the change log.message.format and inter.broker.protocol version. 5. What changes are required on consumer and producer side after changed the version. Thanks, Nilesh
... View more
04-02-2018
10:40 AM
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
Labels:
- Labels:
-
Apache Kafka
01-25-2018
12:45 PM
What does inter.broker.protocol.version in Kafka?
... View more
Labels:
- Labels:
-
Apache Kafka
01-16-2018
01:06 PM
@Harald Berghoff Thank you for the reply. How to check this in zookeeper.
... View more
01-16-2018
01:00 PM
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
Labels:
- Labels:
-
Apache Kafka
11-30-2017
03:14 PM
Hi, How producer and consumer identify the leader in Kafka. Thank you.
... View more
Labels:
- Labels:
-
Apache Kafka
11-29-2017
03:36 PM
Hi, Is there any command to check Kafka version. Thank you.
... View more
Labels:
- Labels:
-
Apache Kafka
11-27-2017
09:21 AM
Hi @ Abdelkrim Hadjidj Thank you for the reply. My question is I am ingesting same data again and again on the same topic then what will happen? Will it overwrite the data or will make another copy of data or it will just ignore and notify? Thank you.
... View more
11-22-2017
02:43 PM
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
Labels:
- Labels:
-
Apache Kafka