kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From wei <sw90...@gmail.com>
Subject how to produce/consume kafka through ssh tunnel
Date Thu, 02 Mar 2017 22:44:54 GMT
We have kafka setup on staging environment, when debug the consumer we want
to directly listen to the kafka on staging environment. I set tunnel but it
seems i can't produce or consume from my local machine. I can create topic
though. I have no problem to produce/consumer on other machine in staging

kafka version: kafka_2.12-
kafka setup: port 9090/9091 on host on staging environment
zookeeper: port 2181 on
tunnelling: -L 9090: -L 9091: -L 2181:

$ bin/kafka-console-producer.sh --broker-list localhost:9091 --topic test
test msg
[2017-03-02 14:43:21,414] ERROR Error when sending message to topic test
with key: null, value: 8 bytes with error:
org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for
test-0: 1503 ms has passed since batch creation plus linger time

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message