spring-kafka Questions
1
I have a spring boot (2.1.6) application that both consumes and produces messages to a (organization wide) common kafka instance. I am trying to implement health checks for this kafka broker in my ...
Tjirebon asked 11/12, 2019 at 13:54
3
Solved
Anyone know if a single listener can listens to multiple topic like below? I know just "topic1" works, what if I want to add additional topics? Can you please show example for both below? Thanks fo...
Reichsmark asked 25/1, 2017 at 20:36
7
Solved
I am manually starting Zookeeper, then Kafka server and finally the Kafka-Rest server with their respective properties file. Next, I am deploying my Spring Boot application on tomcat
In the Tomcat ...
Convent asked 25/12, 2017 at 15:31
1
Solved
I am building a Kafka Listener / Consumer with Spring Boot that consumes Avro data from a topic.
Here's some of the properties
spring.kafka.properties.specific.avro.reader=true
spring.kafka.consume...
Dichloride asked 6/5 at 11:1
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
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
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
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
4
Getting the following error (Kafka 2.1.0):
2018-12-03 21:22:37.873 ERROR 37645 --- [nio-8080-exec-1]
o.s.k.support.LoggingProducerListener : Exception thrown when
sending a message with key='n...
Selfregulated asked 4/12, 2018 at 3:27
6
Solved
I have the consumer config as follows
package com.example.kafka.config;
import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.common.serialization.StringDeserializer;
im...
Sialkot asked 21/7, 2022 at 14:33
2
Solved
Kafka consumer has processed the messages 1, 2, 3, 4 and the enable.auto.commit is set to false.
But on restarting the consumer, it is not reprocessing the above messages again, from CLI I could s...
Rudnick asked 19/5, 2020 at 7:42
3
Solved
I am attempting to load in multiple topics to a single @KafkaListener but am running into trouble as I believe it is looking for a constant value, but initializing the topics variable from the appl...
Margretmargreta asked 5/7, 2017 at 19:21
5
Solved
I'm doing a simple kafka example project with Springboot and I'm having the error where the producer don't create but the rest works well.
The errors that I have it seems that it threw a exception...
Anastaciaanastas asked 5/6, 2019 at 18:6
4
I am using spring boot 2.1.9 with spring Kafka 2.2.9.
My spring boot application was idle from the last 2 weeks, it's running but still, no one accessing the API. But when today I started using, f...
Sandglass asked 18/12, 2019 at 18:32
5
I'm having an issue with swagger ui after upgrading to spring boot 3. The swagger-ui doesn't work anymore and I got a 404 and "White Label" page as response.
After taking a closer look, I...
Accustom asked 14/3, 2023 at 11:52
3
I'm using spring boot to run kafka consumer with Json Deserializer. When running the application I'm getting the error
Caused by: java.lang.NoSuchFieldError: READ_UNKNOWN_ENUM_VALUES_USING_DEFAULT_...
Smoulder asked 15/5, 2023 at 19:43
3
Solved
Use Case:
I am using Spring Boot 2.2.5.RELEASE and Kafka 2.4.1
JAAS/SASL configurations are done properly on Kafka/ZooKeeper as topics are created without issue with kafka-topics.bat
Issue:
When i...
Folketing asked 24/3, 2020 at 5:21
2
Solved
When I set enable.auto.commit to false and try to manually commit offset using annotation based spring-kafka @KafkaListener, I get a org.springframework.kafka.listener.ListenerExecutionFailedExcept...
Dismissive asked 27/6, 2017 at 19:17
3
I am using kafka_2.11-2.1.1
and Producer using spring 2.1.0.RELEASE.
I am using spring while I am sending the messages to Kafka topic my producer generates a lot of TimeoutExceptions
org.apache.k...
Exactitude asked 28/6, 2019 at 12:43
3
Solved
I am working on Spring Boot Kafka example from Confluent and running the simple producer example and getting below error. I am using Windows machine and installed ubunt 14.04 LTS on windows.
Note -...
Elveraelves asked 30/5, 2021 at 15:52
1
We have an integration test where we use EmbeddedKafka and produce a message to a topic, our app processes that message, and the result is sent to a second topic where we consume and assert the out...
Aikens asked 18/3, 2021 at 20:12
1
Solved
There are so few examples of different methods of error-handling in spring cloud streams, and the few that are provided partially via the documentation don't seem to work either.
I have a test repo...
Surreptitious asked 15/7, 2023 at 23:47
3
Solved
In my spring boot kafka publisher application, I want to provide support for publishing messages both in String(json) or in byte format, because I want to provide support for both json and avro. Bu...
Cimex asked 12/9, 2019 at 10:44
5
Solved
I have an application that may need multiple producers. All code samples I see seem to support a single producer, reading config from app during app startup. If there are multiple producers and we ...
Oology asked 24/2, 2018 at 3:42
1 Next >
© 2022 - 2024 — McMap. All rights reserved.