Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Structured Streaming error py4j.protocol.Py4JNetworkError: Answer from Java side is empty

Sarama cannot talk to the Kafka server

go apache-kafka sarama

Failed to connect to and describe Kafka cluster. Check worker's broker connection and security properties

How to run a Kafka Canary Consumer

Spring Kafka ChainedKafkaTransactionManager doesn't synchronize with JPA Spring-data transaction

Is it possible to deserialize Avro message(consuming message from Kafka) without giving Reader schema in ConfluentRegistryAvroDeserializationSchema

Value split is not a member of (String, String)

How to connect to external Oracle database in Docker

Spring Boot Job scheduler with Kafka consumer

Ruby Kafka Uncaught exception: Failed to find group coordinator

How to generate pojo from kafka avro record?

Is there a way to configure JMeter to listen to a kafka topic?

jmeter apache-kafka

Microservices: API Call Vs Messaging. When to Use?

Maximum value for zookeeper.connection.timeout.ms

Kafka connection transformations. Parse input string and get a record key

Why Debezium Connector can't connect to a SASL activated broker?

Read Kafka message and set that message is processing by client

apache-kafka

What happens if you delete Kafka snapshot files?

apache-kafka recovery

Is it possible to set the 'acks' (acknowledgement) property other than in Producer configuration

GCP dataproc - java.lang.NoClassDefFoundError: org/apache/kafka/common/serialization/ByteArraySerializer