英文: How kafka producer works in asynchronous mode 问题 以下是您提供的代码的翻译部分: 我有一个简单的代码来发送消息 private static v...
Kafka重试属性不按预期工作。
英文: Kafka retry property not working as expected 问题 我已经使用版本2.8.1设置了Kafka,基本配置为1个Broker、1个Topic和1个Par...
Kafka的”Exactly Once”语义和max-poll-records
英文: Kafka "Exactly Once" semantics and max-poll-records 问题 I'm kind of confused about max....
Kafka的”Exactly Once”语义和max-poll-records
英文: Kafka "Exactly Once" semantics and max-poll-records 问题 I'm kind of confused about max....
Is there a way to use kafka consumers and producers in the same Python file using confluent_kafka
英文: Is there a way to use kafka consumers and producers in the same Python file using confluent_kafk...
如何限制Kafka消费者拉取的数据量(以字节为单位)?
英文: How to limit kafka consumer poll result in bytes? 问题 我的设置有三个Kafka代理和十几个主题,每个主题有15个分区。 Java应用程序启动...
I have more data in a kafka topic but when i extract data using my pyspark application, I am getting only 1 row extracted, how to fix?
英文: I have more data in a kafka topic but when i extract data using my pyspark application, I am get...
Kafka集群中的理想主题数量
英文: Ideal number of Kafka topics per Kafka cluster 问题 我们有一个使用案例,我们希望有大约2000个Kafka主题(我们有3个代理),每个主题有1个...
将一个带有onSuccess/onFailure的ListenableFuture重构为一个CompletableFuture。
英文: Refactor a ListenableFuture (with onSuccess/onFailure) into a CompletableFuture 问题 因为升级了Kafka库,我...
获取由微服务生产和消费的Kafka主题
英文: Obtaining kafka topics produced and consumed by a microservice 问题 Kafka中是否有任何可用于查看微服务生产和消费的所有主题的...
41