apache-kafka Questions
2
I am using native apache kafka and not confluent's edition of kafka.
I am using using kafka jdbc connector pluggin. I intend to put a break point and inspect through my IDE (intelliJ).
How to mak...
Becnel asked 14/9, 2018 at 8:45
4
ERROR Error while creating ephemeral at /brokers/ids/0, node already exists and owner '72067757872119809' does not match current session '72067836689711106' (kafka.zk.KafkaZkClient$CheckedEphemeral...
Stadtholder asked 5/5, 2021 at 9:59
3
Solved
I am developing Spring Boot + Apache Kafka + Apache Zookeeper example. I've installed/setup Apache Zookeeper and Apache Kafka on my local Windows machine. I've taken a reference from link: https://...
Lumenhour asked 14/12, 2018 at 16:55
2
I'm trying to implement reactive kafka consumer in my Spring boot application and I'm looking at these examples:
https://github.com/reactor/reactor-kafka/blob/master/reactor-kafka-samples/src/main/...
Untraveled asked 1/12, 2020 at 19:24
1
Solved
How to perform error handling in Spring XML + Kafka App? I am using JSON to produce and consume messages, but when consumer gets junk data, its running endless loop.
Here is what I used
spring.xml
...
Tigon asked 18/4 at 14:14
3
As per the definition of "default" attribute in Avro docs: "A default value for this field, used when reading instances that lack this field (optional)."
This means that if the corresponding fiel...
Flitting asked 26/2, 2018 at 9:59
6
this is one part of my Kafka server.properties configurations:
listeners=SSL://192.168.78.131:9092
ssl.keystore.location=/home/linuxea/encr/server.keystore.jks
ssl.keystore.password=linuxea
ssl.ke...
Cloakroom asked 18/4, 2018 at 6:14
6
Solved
I am using this docker-compose setup for setting up Kafka locally: https://github.com/wurstmeister/kafka-docker/
docker-compose up works fine, creating topics via shell works fine.
Now I try to c...
Broncobuster asked 23/12, 2017 at 15:55
2
Solved
I have a problem communicating with Kafka secured with sasl using console scripts. Kafka is secured with sasl, listener is SASL_PLAINTEXT and mechanism is PLAIN.
What I did:
I tried listing some d...
Ruffled asked 18/8, 2017 at 12:22
5
I'm writing a consumer which listens to a Kafka topic and consumes message whenever message is available. I've tested the logic/code by running Kafka locally and it's working fine.
While writing ...
Celadon asked 20/8, 2019 at 13:42
7
I was trying to install one of my go files. But I bumped into this error
C:\mygoproject>go install kafkapublisher.go
\#command-line-arguments
.\kafkapublisher.go:8:65: undefined: kafka.Message
...
Kinetic asked 17/3, 2020 at 17:17
5
Solved
Failed to resolve 'kafka:9092': Name or service not known - docker / php-rdkafka [duplicate]
I am trying to get php connecting to kafka all within a docker container.
kafka php lib - https://github.com/arnaud-lb/php-rdkafka/
kafka docker container - https://hub.docker.com/r/wurstme...
Tapis asked 29/3, 2017 at 20:7
3
Solved
producer sends messages 1, 2, 3, 4
consumer receives messages 1, 2, 3, 4
consumer crashes/disconnects
producer sends messages 5, 6, 7
consumer comes back up and should receive messages starting...
Tysontyumen asked 18/1, 2018 at 11:50
5
Solved
I'm getting up an application consuming kafka messages.
I followed Spring-docs about Deserialization Error Handling in order to catch deserialization exception. I've tried the failedDeserialization...
Salvo asked 30/4, 2019 at 15:9
13
Solved
I´m using zookeeper 3.4.8 in single node and try to use kafka.
When I run this command:
zookeeper-server-start.sh /usr/local/kafka_2.9.2-0.8.2.2 /config/zookeeper.properties
I get the below err...
Kilbride asked 22/2, 2016 at 19:1
3
Solved
If a topic has 4 partitions, and a publisher sends a message to the topic, will that same message be replicate across all four partitions or only one?
Phelips asked 27/6, 2017 at 18:36
15
Solved
Kafka enthusiast, need little help here. I am unable to start kafka because the file \00000000000000000000.timeindex is being used by another process. Below are the logs:
[2017-08-09 22:49:22,811]...
Lamellar asked 9/8, 2017 at 19:59
2
Solved
We are considering to use Kafka in our for messaging and our applications are developed using Spring. So, we have planned to use spring-kafka.
The producer puts the message as HashMap object into ...
Kacykaczer asked 29/6, 2018 at 7:21
14
Solved
After a Kafka topic has been created by a producer or an administrator, how would you change the number of replicas of this topic?
Tungstite asked 22/6, 2016 at 7:2
4
Solved
I have a cluster configuration using Kubernetes on GCE, I have a pod for zookeeper and other for Kafka; it was working normally until Zookeeper get crashed and restarted, and it start refusing conn...
Desmarais asked 21/8, 2017 at 20:19
2
Solved
My Apache Kafka producer (0.9.0.1) intermittently throws a
org.apache.kafka.common.errors.NotLeaderForPartitionException
My code that performs the Kafka send resembles this
final Future<Reco...
Anselme asked 28/4, 2016 at 14:23
15
Solved
I am attempting a simple kafka config on Windows os. My zookeeper and kafka installations use default configs (except for data and log dir paths). I can start kafka and produce/consume messages wit...
Gymnosperm asked 2/8, 2018 at 1:46
2
Solved
I implemented a bunch of integration tests using EmbededKafka to test one of our Kafka streams application running using spring-kafka framework.
The stream application is reading a message from a ...
Valera asked 16/6, 2020 at 6:34
5
We have encountered few exception on production environment:
UnknownTopicOrPartitionException: This server does not host this topic-partition
As per my analysis, one possible workaround for thi...
Magnetics asked 13/6, 2017 at 7:26
7
Solved
I'm looking for a way to delete (completely remove) consumed records from a Kafka topic. I know there are several ways of doing this, by either changing the retention time for the topic or removing...
Hiragana asked 11/7, 2018 at 10:57
© 2022 - 2024 — McMap. All rights reserved.