apache-kafka 相关问题

Apache Kafka 与 Redpanda 的性能测试

我目前正在物联网模拟场景中评估 Apache Kafka 与 Redpanda 的吞吐量和延迟。您能否建议如何为 Apache Kafk 设置性能测试环境...

Kafka幂等生产者

根据文档，幂等的 kafka 生产者维护一个序列号，确保事件的重复数据删除和排序。 这是否意味着在单个制作人会话中，

每个任务的 KafkaProducer 或单例 KafkaProducer

我有几个并行运行的任务（ExecutorService 和 Runnable 任务）。对所有这些都使用一个 KafkaProducer 实例（Spring singleton bean）是一个好的选择吗？在这种情况下，如何

org.springframework.kafka.support.serializer.ErrorHandlingDeserializ'类型为serializer.ErrorHandlingDeserializer]，同时设置构造函数参数

通过参考：How to handle the exception at Consumer in Spring XMl App?，我试图在 xml bean 中转换 Java bean 依赖关系并面临以下错误。 有人可以解释一下...

Kafka Consumer 无法间歇性解析监听器方法

我在卡夫卡消费者端遇到了下面的异常。令人惊讶的是，这个问题与旧版本的代码不一致（具有完全相同的配置，但有一些新的不相关...

Spring XMl App中consumer端如何处理异常？

如何在Spring XML + Kafka App中进行错误处理？我正在使用 JSON 来生成和消费消息，但是当消费者获取垃圾数据时，它会运行无限循环。 已在此处上传代码：https://

DI-kafkaMeter 发送消息错误

我使用jmeter DI-kafkaMeter向kafka发送消息 向 kafka 主题发送消息时出错：java.lang.RuntimeException：找不到 Kafka Producer Client。检查 KafkaProducerSampler 中的变量名称。 ...

Kafka 3.4，带有 Kraft，没有 Zookeeper，有 3 个经纪人

我需要 1 个 kafka 集群和 3 个 kraft borker。 我尝试使用下面的 docker 配置： 第一个经纪人的配置： 版本：“3” 服务： 卡夫卡-1： 图片：“bitnami/kafka：3.4.0” 主机...

如何使用Spring XML触发Kafka Consumer？

我开发了一个 Spring XML + Kafka 示例。在这个例子中，我想了解如何触发它的消费者端。我不想为消费者使用 main 方法。 主应用程序.java 公开课妈...

在 avro 架构中使用“默认”

根据 Avro 文档中“默认”属性的定义：“此字段的默认值，在读取缺少此字段的实例时使用（可选）。” 这意味着如果相应的字段...

camel支持Kafka消费者的事务吗？

需要有从kafka读取事务路由->保留在db中->发布到MQ。 所有这一切都应该在一个事务中发生，如果 DB 或 Commit to MQ/JMS 失败，那么 kafka 消息不应该是

Kafka - 在丢弃之前存储未消费的消息

根据此处的 Kafka 文档。 Kafka 集群会在可配置的时间段内保留所有已发布的消息（无论它们是否已被消费）。例如，如果日志保留是...

Kafka服务器SSL配置异常

这是我的 Kafka server.properties 配置的一部分： 听众=SSL://192.168.78.131:9092 ssl.keystore.location=/home/linuxea/encr/server.keystore.jks ssl.keystore.password=linuxea ssl.key.

Spring boot kafka - 如何告诉 JsonDeserializer 忽略类型标头？

Spring 的 Kafka 生产者将类型标头嵌入到消息中，该消息指定消费者应将消息反序列化到哪个类。当生产者不使用 Spring Kafka 时，这是一个问题...

如何在连接器级别设置转换器属性？

我需要使用以下属性： value.converter.ignore.default.for.nullables=true 在我的设置中，正如此处提到的那样。 当我将其设置为环境变量时，一切正常：

无法在Kafka消费者中显示消息

我正在阅读雅虎财经API以获取多个股票价格并将其发送到工作正常的kafkaProducer。 代码如下 将 yfinance 导入为 yf 从并发.futures 导入

Spring boot Redis 和 Kafka 序列化错误

我们使用Spring Cloud Stream向kafka生成事件，一切都工作正常，直到我们开始引入redis缓存。 我认为出于某种原因，Redis 和 Kafka 的结合在

Kafka 模拟注册表用于测试

我已经在我的 spring 属性文件中设置了： spring.kafka.properties.schema.registry.url=mock://localhost 但是当我运行测试时，我得到以下结果： 引起的：org.apache.kafka.common.errors.

ruamel.yaml 在 Docker 上使用 Pyflink 时出现解析器错误

我正在尝试运行一个 flink 作业，该作业消耗来自/到 kafka 源的数据。为了提交作业，我正在使用 pyflink 库。 我在用着： Python 3.8.0 弗林克1.19.0 docker 文件...

如何通过kafka传播开放遥测跨度？

我想将跟踪从一个服务传播到另一个我通过 Kafka 发送数据的服务。 我能够使用以下逻辑创建子跟踪。但是，opentelemetry 代理不会发送 c...