英文: Kafka ensuring consumer group stays alive 问题 我有一个在独立的Kubernetes Pod中生成生产者和消费者的过程。我想使用auto.offset...
144评论apache-kafka
python
Kafka 确保消费者组保持活跃
144评论apache-kafka
python
144评论apache-kafka
python
Apache Kafka启动错误 – 配置消息格式版本的值无效 3.0-IV1。
英文: Apache Kafka StartUp Error - Invalid value 3.0-IV1 for configuration message.format.version 问题 我...
79评论apache-kafka
Kafka消息轮询增加尝试
英文: Kafka message poll increase attempt 问题 当前KAFKA Consumer的设置如下： max_poll_records: 2000 max_poll_in...
87评论apache-kafka
scaling
记录更多来自Kafka源连接器的数据。
英文: Log more data from Kafka Source Connector 问题 我在AWS中安装了Kinesis Connector插件，用于将我的Kinesis流与我的MSK集群连...
93评论apache-kafka
apache-kafka-connect
记录更多来自Kafka源连接器的数据。
英文: Log more data from Kafka Source Connector 问题 我在AWS中安装了Kinesis Connector插件，用于将我的Kinesis流连接到我的MSK集...
80评论apache-kafka
apache-kafka-connect
无法在反应式 Kafka 中使用 schemaRegistry。
英文: Unable to use schemaRegistry in reactor kafka 问题 我正在尝试使用Reactor Kafka设置Kafka消费者。生产者已经与Kafka模式注册表...
108评论apache-kafka
java
如何使用`consumerseekaware`接口以从特定的Kafka偏移位置获取Kafka消息。
英文: how to use consumerseekaware interface in order to fetch kafka message from a paticluar kafka of...
133评论java
spring-boot
Unable to create a Kafka topic using Confluent while the broker is running in a docker container.
触发Kafka主题中的压缩应如何操作？
英文: How to trigger compaction in Kafka topic? 问题 我使用以下设置创建主题： final AdminClient localKafkaAdmin = Ad...
82评论apache-kafka
kafka-consumer-api
如何停止 Dapr Kafka 组件连接到已关闭的消费者组？
英文: How can I stop Dapr Kafka Component from connecting to closed consumer groups? 问题 我在Kubernetes中有...
88评论apache-kafka
sarama