Created on 04-02-2018 01:17 AM - edited 09-16-2022 06:03 AM
When i am trying to sending data to topic. using this command
kafka-console-producer --broker-list hostname:9092 --topic topic name
Getting this lines as a output of command
18/04/02 01:09:49 INFO utils.AppInfoParser: Kafka version : 0.10.2-kafka-2.2.0 18/04/02 01:09:49 INFO utils.AppInfoParser: Kafka commitId : unknown
Env
CDH version 5.13 package
Any help would be much appreciated ?
Created 04-02-2018 01:53 AM
Created 04-02-2018 02:00 AM
Created 04-02-2018 02:02 AM
Created 04-02-2018 02:03 AM
Created 04-02-2018 02:12 AM
[cloudera@quickstart bin]$ kafka-console-producer --broker-list hostname:909 2 --topic planedate SLF4J: Class path contains multiple SLF4J bindings. SLF4J: Found binding in [jar:file:/usr/lib/kafka/libs/slf4j-log4j12-1.7.21.jar!/ org/slf4j/impl/StaticLoggerBinder.class] SLF4J: Found binding in [jar:file:/usr/lib/kafka/libs/slf4j-log4j12-1.7.5.jar!/o rg/slf4j/impl/StaticLoggerBinder.class] SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory] 18/04/02 02:09:46 INFO producer.ProducerConfig: ProducerConfig values: acks = 1 batch.size = 16384 block.on.buffer.full = false bootstrap.servers = [172.27.54.65:9092] buffer.memory = 33554432 client.id = console-producer compression.type = none connections.max.idle.ms = 540000 interceptor.classes = null key.serializer = class org.apache.kafka.common.serialization.ByteArraySe rializer linger.ms = 1000 max.block.ms = 60000 max.in.flight.requests.per.connection = 5 max.request.size = 1048576 metadata.fetch.timeout.ms = 60000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.De faultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.ms = 50 request.timeout.ms = 1500 retries = 3 retry.backoff.ms = 100 sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 102400 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS timeout.ms = 30000 value.serializer = class org.apache.kafka.common.serialization.ByteArray Serializer 18/04/02 02:09:46 INFO utils.AppInfoParser: Kafka version : 0.10.2-kafka-2.2.0 18/04/02 02:09:46 INFO utils.AppInfoParser: Kafka commitId : unknown >hi howdy
Created 04-02-2018 02:13 AM
Created 05-09-2018 02:42 AM
Hello,
I'm facing the same error and when i try to send text via producer, the following error appears:
[cloudera@quickstart ~]$ kafka-console-producer --broker-list localhost:9092 --topic test2
18/05/09 02:21:28 WARN clients.NetworkClient: Connection to node -1 could not be established. Broker may not be available.
my question is how to let zookeeper know about the broker id because it seems that zookeeper is not detecting the broker.
Created 05-15-2018 02:09 AM
Hi @Murad
Check in zookeeper cli the broker id under /<kafkaroot>/brokers/ids/
You need not do anything to let zookeeper knoe about the kafka brokers. The above should give the brokers connected to zookeeper (the ids has to be same as the ids in kafka configurations)
Created 05-15-2018 02:11 AM
Hi @Neo
You are already producing messages! you can check the message in the .log file of your topic partitions.