Logo Questions Linux Laravel Mysql Ubuntu Git Menu
HTML CSS JAVASCRIPT SQL PYTHON PHP BOOTSTRAP JAVA JQUERY R React Kotlin
 

New posts in apache-kafka

How does kafka know whether to "roll forward or roll back" a transaction?

apache-kafka kafka-producer-api

kafka IllegalStateError: Producer is closed forcefully

python python-3.x apache-kafka kafka-producer-api

How to select the Key of a Record in a Select statement

apache-kafka ksqldb

Spring Kafka | How to make DeserializationException retryable?

java spring-boot apache-kafka spring-kafka spring-retry

Does retention.bytes in Kafka limit the size of a partition per replica or a partition's all replica combined?

apache-kafka

Spring kafka @KafkaListener is not being invoked

java spring apache-kafka spring-kafka

Logstash 5.1.1 kafka input doesn't pick up existing messages on topic

elasticsearch apache-kafka logstash apache-zookeeper

Kafka Producer config retry strategy

python apache-kafka kafka-producer-api rsyslog confluent-platform

Circuit breaker with kafka consumer

spring apache-kafka kafka-consumer-api circuit-breaker

Can we use multiple kafka template in spring boot?

apache-kafka spring-kafka kafka-producer-api

retrieve messages in a topic using kafka-python

python apache-kafka kafka-consumer-api kafka-python

How to create a list of topics in Apache Kafka using single command

unix apache-kafka apache-zookeeper

Running kafka connect in Distributed mode?

apache-kafka kafka-consumer-api apache-kafka-connect confluent-platform

kafka bootstrap.servers as DNS A-Record with multiple IPs

apache-kafka spark-streaming flume high-availability resolve

Kafka consumer not consuming from beginning

apache-kafka kafka-consumer-api kafka-producer-api kafka-topic

Py4JJavaError: An error occurred while calling o45.load. : java.lang.NoClassDefFoundError: org/apache/spark/sql/sources/v2/StreamWriteSupport

docker pyspark apache-kafka docker-compose apache-spark-sql

Is there a limit on consumers and consumer groups?

apache-kafka

Spring Kafka - How to set Commit Async property

spring spring-boot apache-kafka yaml spring-kafka

How to map input KStream <String,String> into <String, CarClass> using KeyValueMapper?

apache-kafka apache-kafka-streams
Older Entries »