Category "apache-kafka"

GCP PubSub java client's Publisher - concurrency not working Multi threaded environement

I am trying to consume messages from Kafka and publish them to Google PubSub. We have 4 Kafka concurrent consumer threads and I injected the Google pubsub clien

GCP PubSub java client's Publisher - concurrency not working Multi threaded environement

I am trying to consume messages from Kafka and publish them to Google PubSub. We have 4 Kafka concurrent consumer threads and I injected the Google pubsub clien

Can we have spring cloud stream working with just the application.yml properties?

I need to create an application which has to bridge multiple Queue solutions like Rabbitmq, Kafka, Azure eventhub. I am thinking to use Spring cloud Stream so t

How to expose kafka using istio ingress?

I use istio-ingress gateway and virtualservice to expose different microservices. So far all of them have been http services, so it was straight-forward to foll

Kerberized Apache Kafka consumer not creating groups

I am using version 2.13. Kafka is able to produce messages but not able to consume messages after investigation I found that consumer groups are not getting cre

ksqldb high disk usage problem(disk usage tends to increase indefinitely)

I am currently using Ksqldb in the k8s environment. I am using TABLE for aggregate operations. Since it is a stateful operation, ksqldb is expected to be using

Kafka EOS retry flag

I have a Kafka cluster and a spring boot application that is configured for EOS. The application consumes from topic A performs some business logic then produce

Flink - InstanceAlreadyExistsException: while migrating to the KafkaSource

I am using flink with v1.13.2 . And I am trying to migrate FlinkKafkaConsumer to KafkaSource. While i am testing new KafkaSource, i am getting the following exc

Generate Kafka message with Headers using Apache Spark

I have an ETL (spark-scala). After writing in a table, a message with "header" must be sent to Kafka. I couldn't add the header in the message. I have a spark D

kafka retry many times when i download large file

I am newbie in kafka, i try build a service send mail with attach files. Execution flow: Kafka will receive a message to send mail function get file will downlo

Perform streaming aggregations on CDC events that contain deletes/updates

A friend reached out and told me that he'd built a data pipeline that captures changes from MySQL using the Debezium connector, and then performs streaming aggr

Spring cloud streams kafka streams state store

I want to get state store with custom key and value. I have a kafka topic example-kafka-topic-event. This is how I get ktable at the code level: @Component("exa

Kafka Mirrormaker2 config optimization

I am setting up Strimzi kafka Mirrormaker2 in our test environment which receives on an average 100k messages/5 mins. we have around 25 topics and 900 partition

confluentinc/cp-kafka docker log4j warnings

docker pull confluentinc/cp-kafka I use this code to pull the kafka image. Then, use the following to start the containers. docker run --rm -d --name kafka-se

Kafka streams change thread count based on replica count

I have a relatively simple setup where I'm running a dynamic number of instances of my stateless Kafka streams app based on my consumer group lag. This is achie

Sarama Cluster Admin - Broker Connected method return false

Versions Sarama - v1.32.0 Kafka - 5.4.6-2.12 Go - v1.16.2 sarama.Logger = log.New(os.Stderr, "[Sarama] ", log.LstdFlags) brokers := []string{ "kafka1

What should be the ideal Kafka "RequestMetrics.RemoteTimeMs" value for FetchConsumer specifically?

Kafka 0.11.0 Documentation mentions the normal values for the MBean "RequestMetrics.RemoteTimeMs" as "non-zero for produce requests when ack=-1" Link to officia

Spring Kafka Batch listener not receiving more than 1 or 2 messages

Spring Kafka Batch consumer receives only one or two messages we have increased fetch.min.bytes to 9000 and fetch.max.wait.ms 5000 [Based on this answ

Listener for Python Queue

I'm using python queue to insert data packets from mqtt listeners But I'm not sure when this queue will be loaded by Mqtt packet. Can we put a listener on to th

How do I set auto.create.topics.enable=true in docker image johnnypark/kafka-zookeeper so that new topics are created automatically?

In docker image johnnypark/kafka-zookeeper new topics are not created automatically. How do I set auto.create.topics.enable=true in this docker image johnnypark