Quarkus BackPression管理
我使用quarkus反应性消息和kafka获得了以下堆栈跟踪...
Apache Camel 2.18.0 Consumer不使用
我们正在使用Apache骆驼到2.17。*版本，以便利用max...
Kafka-python Producer执行发送，但是没有数据到达Kafka
我正尝试通过python作为远程生产者将数据发送到Kafk...
卡夫卡消费者fetch-min-sizefetch.min.bytes是否在等待上述大小被填满？ fetch.min.bytes fetch.max.wait.ms
假设有107条记录，每条记录为1kb。如果提取大小为15...
将Avro消息推送到kafka主题
我正在尝试使用<strong> kafka-node-avro <...
错误运行使用者时发生未知错误：org.apache.kafka.common.errors.SerializationException：未知魔术字节
正在尝试从python向kafka消费者发送消息。但是由于&...
无法编译Maven项目
我使用汇合的人工制品开始了一个简单的项目。但是，...
无法连接到容器外部的Kafka
我正在尝试对我的应用程序进行黑盒测试。所以我创建...
RHEL上的Kafka给我“类路径为空”
我正在尝试在Red Hat VM上安装Kafka 2.6.0。当我尝试...
gRPC vs NATS或Kafka是否有意义？
在很长一段时间里，谈到微服务架构，NATS和Kafka是我...
org.apache.camel.CamelExchangeException的AggregationStrategy：无效的关联密钥
我想汇总3个主题，但仅针对汇总策略的PoC，我尝试汇...
Kafka的Spring Boot-一个应用程序中的多个KafkaStreams配置
在春季，kafka流可以在一个应用程序中定义两个配置吗...
Spring Boot的Kafka-Streams示例
我是Apache Kafka的新手，我创建了一个简单的Spring...
在Google云平台上使用kafka主题的最佳地点是哪里？
我们在Google云上开发了微服务架构。 实际上，所有微...