Skip to main content

All Questions

0 votes
0 answers
45 views

Error starting Kafka Broker in a Kraft Cluster

I would like to set up 3 Brokers and 3 Controllers with option to expanding. Here is my Docker Compose file: services: # 📌 Controller-1 kafka-controller-1: image: bitnami/kafka:latest ...
Tree's user avatar
  • 31.5k
0 votes
1 answer
230 views

Kafka authentication with scram 512 and KRAFT mode doesn't work

Kafka authentication with scram 512 and KRAFT mode doesn't work. My docker compose looks like this. services: kafka-1: image: confluentinc/cp-kafka:7.7.1 ports: - '9092:9092' ...
Casper T's user avatar
0 votes
0 answers
293 views

Apache Kafka Kraft - Cancelled in-flight API_VERSIONS request

acks = -1 auto.include.jmx.reporter = true batch.size = 16384 bootstrap.servers = [localhost:9092, localhost:9094, localhost:9096] buffer.memory = 33554432 client.dns.lookup = ...
elenwen's user avatar
  • 47
0 votes
0 answers
13 views

Microservice doesn't map ports correctly on Kafka [duplicate]

My microservice application throws a continuous error while trying to use Kafka. I am testing several configuration possibilities and I cannot understand why it doesn't work. Configuration of ...
Thorvas's user avatar
  • 83
0 votes
1 answer
1k views

Docker Compose with Java Spring Boot and Apache Kafka Bitnami (KRaft without Zookeeper)

I'm trying to send some event to topic "helloworld" from Spring Boot Producer to Apache Kafka (KRaft without Zookeeper). I use following URL: http://localhost:8080/helloworld/name/Chris As ...
Chris's user avatar
  • 1
-1 votes
1 answer
462 views

Kafka consumer application fails to connect with Azure eventhubs with docker compose but works fine with docker

I have a Java application which works fine using docker. It consumes messages from Azure EventHubs, does some transformations and saves them to a database. The dockerfile is simply: FROM adoptopenjdk:...
jbx's user avatar
  • 22.2k
1 vote
1 answer
7k views

Testcontainers SchemaRegistry can't connect to Kafka container

I want to run integration tests that test my kafka listener and avro serialization. this requires a Kafka and a Schema regsitry (transitively also a Zookeeper). When testing I currently have to a ...
azurius's user avatar
  • 13
2 votes
0 answers
470 views

kafka running in Docker logs: "java.lang.OutOfMemoryError: Direct buffer memory" when receiving payload from Github

We have in our production kafka --version 7.2.1-ccs (Commit:80334008361592c187b36a27536f10f33fe93aa3) running in a docker Container java -version openjdk version "11.0.15" 2022-04-19 LTS ...
Fendri's user avatar
  • 31
0 votes
0 answers
20 views

Docker compose - kafka and zookeper starting before an web app [duplicate]

i try to dockerize my apps and i am tryimng to start 3 containers with docker compose. My docker-compose: version: '3' services: zookeeper: image: wurstmeister/zookeeper ports: - "...
Gumaniuc Alexandru's user avatar
0 votes
1 answer
742 views

Can't send messages to kafka topics in docker-compose

I have written a docker-compose.yml file to allow multiple services to be linked and started at once. I have a jar that sends messages in JSON format to a kafka topic inside a container, only it ...
N7Legend's user avatar
1 vote
0 answers
23 views

Kafka unable to send/receive the message [duplicate]

I'm trying to send a message with Kafka but everytime I send I get this message in the console: My docker compose is: version: '3' services: zookeeper: image: wurstmeister/zookeeper ...
Robs's user avatar
  • 296
0 votes
0 answers
10 views

unable to connect springboot and kafka application when deploying to 2 different servers [duplicate]

this is kafka docker-compose: version: '2' services: zookeeper: image: "confluentinc/cp-zookeeper:5.2.1" environment: ZOOKEEPER_CLIENT_PORT: 2181 ZOOKEEPER_TICK_TIME: ...
Lê Công's user avatar
0 votes
1 answer
5k views

KafkaListener can not receive message after Spring boot application restart

I have an Springboot with Kafka application, and my Kafka cluster start with docker compose file. However, if Kafka cluster keep start, but Spring boot application restart, it can not receive any ...
JoseLuis's user avatar
  • 113
1 vote
1 answer
6k views

how to docker-compose spring-boot with kafka? [duplicate]

Execution is working fine but I think I am missing something, because when I use the REST API it will show: (/127.0.0.1:9092) could not be established. Broker may not be available You may see this ...
user avatar
1 vote
0 answers
23 views

Docker Issue: Can't connect to landoop kafka cluster from docker service in the same docker-compose.yml [duplicate]

When attempting to Dockerize my application, the images and container properly get created. However, when attempting to utilize Docker Landoop Kafka Cluster, my microservice applications (...
Omar Kazimi's user avatar

15 30 50 per page