Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Why enable Record Caches In Kafka Streams Processor API if RocksDB is buffered in memory?

Kafka Connector for Oracle Database Source

How change topic leader or remove partition after some broker down?

Java heap space - Out of memory error - Kafka Broker with SASL_SSL

Are SQS and Kafka same?

apache-kafka amazon-sqs

Unexpected Kafka request of type METADATA during SASL handshake

Kafka get to know when related messages are consumed

Can a kafka consumer group freeze during a rebalance

How to use kafka.group.id and checkpoints in spark 3.0 structured streaming to continue to read from Kafka where it left off after restart?

How Kafka guarantee the messages order while we increase the partitions in runtime?

Could not find io.confluent:kafka-protobuf-serializer:6.0.0

Getting "java.lang.IllegalStateException: Tried to lookup lag for unknown task 3_0" after upgrading Kafka Stream from 2.5.1 to 2.6.2

How can I force socket opened with python to close?

python sockets apache-kafka

Apache Kafka Default Encoder Not Working

apache-kafka

Kafka in distributed system

apache-kafka

Spark + Kafka integration - mapping of Kafka partitions to RDD partitions

Kafka having duplicate messages

Kafka Getting error No resolvable bootstrap urls given in bootstrap servers

Adding custom jars to pyspark in jupyter notebook

How to set group name when consuming messages in kafka using command line?