英文: How kafka producer works in asynchronous mode 问题 以下是您提供的代码的翻译部分： 我有一个简单的代码来发送消息 private static v...
147评论apache-kafka
java
Kafka生产者在异步模式下的工作原理是如何的
147评论apache-kafka
java
147评论apache-kafka
java
Kafka重试属性不按预期工作。
英文: Kafka retry property not working as expected 问题 我已经使用版本2.8.1设置了Kafka，基本配置为1个Broker、1个Topic和1个Par...
121评论apache-kafka
java
Kafka的”Exactly Once”语义和max-poll-records
英文: Kafka "Exactly Once" semantics and max-poll-records 问题 I'm kind of confused about max....
104评论apache-kafka
Kafka的”Exactly Once”语义和max-poll-records
英文: Kafka "Exactly Once" semantics and max-poll-records 问题 I'm kind of confused about max....
103评论apache-kafka
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...
145评论apache-kafka
python
如何限制Kafka消费者拉取的数据量（以字节为单位）？
英文: How to limit kafka consumer poll result in bytes? 问题 我的设置有三个Kafka代理和十几个主题，每个主题有15个分区。 Java应用程序启动...
156评论apache-kafka
kafka-consumer-api
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...
185评论apache-kafka
apache-spark
Kafka集群中的理想主题数量
英文: Ideal number of Kafka topics per Kafka cluster 问题 我们有一个使用案例，我们希望有大约2000个Kafka主题（我们有3个代理），每个主题有1个...
139评论apache-kafka
kafka-topic
将一个带有onSuccess/onFailure的ListenableFuture重构为一个CompletableFuture。
英文: Refactor a ListenableFuture (with onSuccess/onFailure) into a CompletableFuture 问题 因为升级了Kafka库，我...
171评论apache-kafka
java
获取由微服务生产和消费的Kafka主题
英文: Obtaining kafka topics produced and consumed by a microservice 问题 Kafka中是否有任何可用于查看微服务生产和消费的所有主题的...
110评论apache-kafka
spring-kafka
41