apache-kafka

英文: How do I implement in memory or embedded kafka not for testing purposes? 问题 我正在寻求在仅允许由上述应用程序运行的环...

英文: What is the difference between Kafka Template and kafka producer? 问题 我看到 Kafka 模板在内部使用了 Kafka 生产...

英文: Java Spring boot kafka delete message from topic with offset 问题 我正在尝试创建一个Spring Boot应用程序（Java），必...

英文: Few kafka partitions are not getting assigned to any flink consumer 问题 我有一个包含15个分区[0-14]的Kafka主题...

英文: Apache Flume Java client fails to start with a single Kafka sink 问题 使用 org.apache.flume.agent.em...

英文: How to log offset in KStreams Bean using spring-kafka and kafka-streams 问题 我已经几乎参考了关于如何通过Process...

英文: Subscribe to every topic partition 问题 什么是订阅给定Kafka主题多次的规范方法，并且对于每个KafkaConsumer从每个分区接收每条消息。 我目前正...

英文: __consumer_offsets topic showing different configuration when describe with zookeeper and bootst...

英文: How to handler errors/exceptions while using Spring Kafka framework? 问题 我无法找到如何在Spring Kafka消费者中...

英文: KafkaConsumer.commitAsync() behavior with a lower offset than previous 问题 当主题的偏移值以比先前调用的偏移值更小的值给...