python (12.9k questions)
javascript (9.2k questions)
reactjs (4.7k questions)
java (4.2k questions)
java (4.2k questions)
c# (3.5k questions)
c# (3.5k questions)
html (3.3k questions)
KSQL+Streams+Kubernetes Timeout while waiting for command topic consumer to process command
I'm new in k8s and KSQL, so I would be appreciate for any suggestion.
We have an 1 KSQL Server as ETL,3 Kafka,3 Zookeeper and 1 Kafka-Connect Pods in k8s.
While creating new stream we receive an error...

r_k
Votes: 0
Answers: 0
Kafka - how to avoid losing data in emergency situations
Recently, we had a production incident when Kafka consumers were repeatedly processing the same Kafka records again and again, and Kafka was rebalancing all the time. But I do not want to write here a...
xarx
Votes: 0
Answers: 0
Data type information lost when replication MySQL to PostgreSQL via Debezium
I need to replicate a MySQL database to a PostgreSQL database. I opted for:
Debezium connect
Avro format
confluent schema registry
kafka
The data is being replicated, however, I am losing some schem...
miro
Votes: 0
Answers: 1
ClassNotFoundException exception occurred: io.confluent.kafka.security.config.provider.SecurePassConfigProvider (kafka.server.KafkaConfig)
The broker is failed on start-up and I can see the following errors :
INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
ERROR ClassNotFoundException exc...
kuti
Votes: 0
Answers: 1