如何使用Contruent Python从Kafka中的特定分区中消耗数据
我尝试了此代码，但也从其他分区中消耗了 ConsumerKafka.subscribe(topic_list) ConsumerKafka.assign([TopicPartition(topic_name, 1, 2)]) 阅读全文
apache-kafka kafka-consumer-api confluent-kafka-python如何在不阻止kafka消息消耗的情况下运行polly.net
我有一个Kafka消费者，它在消耗消息时会调用外部API。如果呼叫不成功，则将polly.net用作重试机制。 当前解决方案的问题在于，重试机制正在阻止下一条消息的消耗，因此下一条消息必须等待重试机制才能完成。 有什么想法如何异步运行重试机制，以便继续下... 阅读全文
c# .net apache-kafka kafka-consumer-api polly