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

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

apache-spark google-cloud-platform pyspark apache-kafka google-cloud-dataproc

Connect PySpark to Kafka from Docker container

docker apache-spark pyspark apache-kafka docker-compose

ElasticsearchSinkConnector can't connect to Elastic

elasticsearch apache-kafka apache-kafka-connect

Flink not commiting offsets to kafka

java scala streaming apache-kafka apache-flink

How to set Kafka Producer message rate per second?

apache-kafka kafka-producer-api

Kafka List all partition with no leader

apache-kafka apache-zookeeper

Event Sourcing vs Event Driven Architecture difference

apache-kafka cqrs event-sourcing saga event-driven

Embedded Kafka Refresh Messages Between Tests

spring apache-kafka spring-kafka spring-kafka-test

Kafka SASL: OAUTHBEARER and PLAIN simultaniously

authentication oauth-2.0 apache-kafka jaas

Spark Python Avro Kafka Deserialiser

python apache-spark apache-kafka avro spark-streaming

Bean instantiation via factory method failed; exception org.springframework.beans.BeanInstantiationException

java spring spring-boot apache-kafka spring-kafka

Kafka Consumer Group: read new messages only

node.js apache-kafka

Is there a way to update configuration of a running kafka connector

apache-kafka apache-kafka-connect

Read a CSV file in real time using Kafka Connect

java apache-kafka kafka-producer-api apache-kafka-connect

Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

apache-kafka hortonworks-data-platform producer

What is the best practice to retry messages from Dead letter Queue for Kafka

apache-kafka error-handling

What if a Kafka's consumer handles a message too long? Will Kafka reappoint this partition to another consumer and the message will doubly handled?

apache-kafka kafka-consumer-api kafka-partition

How does Apache Kafka use open file descriptors?

apache-kafka

Retrieving Kafka broker properties from a client

apache-kafka

Are Kafka Streams Appropriate for Triggering Batch Processing of Records?

java apache-kafka microservices batch-processing apache-kafka-streams
« Newer Entries Older Entries »