All Questions
Tagged with spring-kafka java
1,506 questions
0
votes
0
answers
21
views
TraceId not printing in kafka-stream application
I have kafka stream application which is running in springboot-2.x, kafka-streams-2.5.1 and spring-cloud-sleuth (log tracing) and I’m using KafkaStreamsTracing for print traceId and spanId. Which is ...
0
votes
1
answer
36
views
Kafka reactor response
My team is developing a chat application that uses Kafka Reactor for the transamition of data between the clients.
One of our problems is the return of feedback to the users. By calling an API like ex....
- 103
0
votes
0
answers
33
views
How to fix: Could not find a 'KafkaClient' entry in the JAAS configuration?
This is the exception I got when I try to send message in my topic on confluent cloud
Caused by: org.apache.kafka.common.KafkaException: Failed to create new NetworkClient
at org.apache.kafka....
0
votes
0
answers
16
views
Kafka producers fail to send after kafka brokers are brought down then up
The Kafka producers in my application fail to write messages to Kafka after Kafka brokers are brought down then up.
Instead, this keeps getting printed:
org.springframework.kafka.core....
- 650
0
votes
0
answers
33
views
best way to use circuitbreaker in kafka listener
I have a spring boot application written in java which has a kafka listener:
@KafkaListener(
autoStartup = "false",
topics = "topic name",
...
- 2,774
0
votes
2
answers
84
views
Kafka Consumer Interceptor not being registered in a spring boot app
I have the following Kafka consumer interceptor class (ApiGatewayKafkaConsumerInterceptor):
package com.demo.api.gateway.kafka.interceptor;
import java.util.Map;
import org.apache.kafka.clients....
0
votes
1
answer
62
views
Kafka deserializing key/value exception: log the original incoming message
I am learning how Kafka handles exceptions. I have a message consumer that expects JSON
incoming data in order to the JsonDeserializer can do its job properly.
If I send an invalid string content to ...
- 22.5k
1
vote
1
answer
52
views
Containerized Kafka Consumer Cannot Connect to Kafka Container
I am trying to implement a microservice architecture using docker and spring boot. I have a kafka container running, as well as a consumer container running. There is also a producer facing the same ...
- 11
0
votes
1
answer
20
views
KafkaServer tests throw Address already in use, when running tests together
I have a Spring application, that starts a local kafka server and I wanted to test it. One test checks if the server is running and the other whether there are messages in the kafka topic.
However, ...
- 101
0
votes
1
answer
36
views
Spring stream kafka events with multiple output topics
I have a springboot app that sends kafka events to a topic with a specific avro schema. The demo code is as so:
@Configuration
@Slf4j
public class KafkaListener {
@Bean
public Function<List<...
- 379
0
votes
1
answer
37
views
How to expose either kafka's ConsumerRecord<K, V>, or Spring cloud Stream's metadata to deserializer?
Spring cloud stream integration permits the users to provide a Function<Message<T>> implementation to handle messages received via some preconfigured MQ implementation, such as kafka. It ...
- 1,287
1
vote
1
answer
75
views
Find another instance to process kafka message
I have 2 SpringBoot applications deployed in AWS, APP1 is managing cars and for each new added car, it will create 2 kafka topics to be used only for that car(topic A for events APP1 -> APP2 and ...
- 55
-3
votes
1
answer
50
views
How to add information about topic to metrics of Spring Kafka Template?
I have metric "spring_kafka_template_seconds_count" but there are no topic information. I use 2.8.11 spring-kafka version. In doc https://docs.spring.io/spring-kafka/reference/kafka/...
- 5
2
votes
1
answer
65
views
Kafka Streams - Why can't I aggregate and sum up my Longs?
I'm new to Kafka Streams and I'm trying to cobble together my first application.
I would like to add up the amounts of my BankTransactions.
@Bean
public KStream<?, ?> kStream(StreamsBuilder ...
0
votes
0
answers
140
views
Topic partition with spring cloud stream. Can not consumer topic
I am trying to produce and consume messages to and from Kafka (using spring cloud streams).
When producing messages I have no problems, using kafbat I can see that the message has been created ...
- 524