spring-kafka Questions
4
My spring-boot application(consumer) process messages from Apache Kafka. Periodically, massage can't process and consumer throw exception. Consumer commits offset anyway.
Can I distinguish succes...
Zenithal asked 8/4, 2019 at 8:9
1
Solved
We are working on spring project and integrated with spring-kafka recently. It's working as expected where we are able produce and consume messages properly.
But as we moved project to PROD, we are...
Kentkenta asked 19/10, 2021 at 14:29
4
I am using Spring Kafka first time and I am not able to use Acknowledgement.acknowledge() method for manual commit in my consumer code as mentioned here https://docs.spring.io/spring-kafka/referenc...
Butte asked 20/9, 2017 at 15:1
2
I have used Swagger to generate a document for rest API, but I am building Kafka listener and wanted to generate a document for it. Do we have any possibility using Swagger or something simil...
Unswerving asked 22/2, 2018 at 15:31
0
Caused by: org.apache.kafka.common.KafkaException: javax.security.auth.login.LoginException: No LoginModule found for org.apache.kafka.common.security.plain.PlainLoginModule
at org.apache.kafka.co...
Paten asked 18/7, 2023 at 9:31
2
Solved
I am trying to setup Kafka Consumer using SpringBoot(1.5.9) and Spring-kafka(2.1.0). However when I start my app I get java.lang.NoSuchMethodError: org.springframework.util.Assert.state(ZLjava/util...
Immutable asked 20/12, 2017 at 18:26
2
Solved
On a very simple Kafka consumer app from tutorial website: https://www.baeldung.com/spring-kafka
But once containerized with openJDK 17, this issue is 100% reprodicible:
ERROR 1 --- [ntainer#0-0-C-...
Desert asked 18/1, 2023 at 13:9
3
Solved
On spring boot 2.6.4, this method is deprecated.
public ConcurrentKafkaListenerContainerFactory<Object, Object> kafkaListenerContainerFactory(
ConcurrentKafkaListenerContainerFactoryConfigur...
Intermixture asked 3/3, 2022 at 0:55
2
Solved
Producer properties
spring.kafka.producer.bootstrap-servers=127.0.0.1:9092
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-se...
Unsought asked 6/12, 2021 at 21:15
2
Solved
I am trying to write the unit test case for ListenableFuture adding Callback but I am not sure how to do it. Didn`t get anything useful on internet.
@Test
public void can_publish_data_to_kafka() ...
Sidonnie asked 22/5, 2019 at 2:45
2
I'm trying to unit test a kafka consumer class, in Spring. I want to know that if a kafka message is sent to it's topic, the listener method was called correctly. My consumer class is annotated lik...
Dismiss asked 7/5, 2018 at 12:29
5
Trying to figure out if I can write unit test for @KafkaListener using spring-kafka and spring-kafka-test.
My Listener class.
public class MyKafkaListener {
@Autowired
private MyMessageProce...
Ender asked 12/10, 2018 at 15:54
5
Solved
i need to test a message, which contains headers, so i need to use MessageBuilder, but I can not serialize.
I tried adding the serialization settings on the producer props but it did not work.
Ca...
Dene asked 25/4, 2017 at 13:29
1
Solved
I am trying to connect to AWS MSK using SASL protocol in a spring boot project. I am using spring-kafka to connect. The error I am getting is
org.apache.kafka.common.KafkaException: javax.security...
Taproot asked 22/12, 2022 at 12:38
2
The Angular Server Sent Event this.eventSource.onmessage call fails with an error "EventSource's response has a MIME type ("application/json") that is not "text/event-stream". Aborting the connecti...
Repeat asked 1/5, 2020 at 16:38
4
I was looking a while and didn't seem to find the answer.
I'm using Spring boot 2, Spring Kafka 2.1.4 and I want to see the kafka consumer metrics in the /metrics endpoint of spring boot actuator.
...
Hegemony asked 27/3, 2018 at 7:27
1
Solved
After upgrading to Spring Boot 3 I've had to update the tracing/correlation configuration to switch from Spring Cloud Sleuth to the new Micrometer Tracing library.
At this point I can see traceId/s...
Echovirus asked 3/12, 2022 at 12:3
3
I have a Spring Boot project that has a Kafka listener that I want to test using Embedded Kafka. I have the Kafka Listener log out the message "record received". Which will only be be log...
Limburger asked 10/11, 2021 at 11:45
4
Solved
We have an issue where it appears that a Kafka consumer is not receiving messages published to a topic. (I say appears as I have not yet got to the bottom of this, and I could be wrong.)
I am usin...
Christianity asked 2/3, 2017 at 10:30
2
I'm using Spring Boot 2.2.0.M4 and Kafka 2.2.0 trying to build an application based on the sample at https://www.baeldung.com/spring-kafka. When I enable the listener for my topic, I get the follow...
Curlew asked 24/7, 2019 at 18:22
5
I am using Spring Kafka first time and I am not able to use Acknowledgement.acknowledge() method for manual commit in my consumer code. please let me know if anything missing in my consumer configu...
Heroism asked 22/11, 2017 at 6:13
4
Solved
I have a basic POJO that contains a java.time.LocalDateTime:
package foo.bar.asire.api.model;
import java.time.LocalDateTime;
public class Address
{
private Long id;
private Integer houseNumbe...
Lox asked 27/5, 2017 at 19:24
2
As I have seen the Kafka template internally used Kafka producer. I just want to know what is the exact difference.
Also, I found many send() methods available in the Kafka template as compared to ...
Cause asked 9/9, 2020 at 8:53
4
I'm working on Spring Boot and Apache Kafka - trying to have a user defined configurations -
org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method could not be invoke...
Recrimination asked 19/2, 2021 at 4:24
2
Solved
I have two services that should communicate via Kafka.
Let's call the first service WriteService and the second service QueryService.
On the WriteService side, I have the following configuration f...
Lucrecialucretia asked 14/2, 2019 at 12:34
© 2022 - 2024 — McMap. All rights reserved.