kafka-producer-api 相关问题

即使配置了公告的侦听器也无法连接到远程kafka代理

我在GCP中创建了一个虚拟机，并在其中设置了kafka。我已将通告的侦听器更改为虚拟机的外部公共IP。但是，无论何时我尝试从本地笔记本电脑进行连接，我都会不断得到...

在Spring boot kafka中的ProducerConfigs中将ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG设置为IntegerSerializer时，它给出类强制转换例外

我正在使用带有kafka的Spring引导程序来设置我的项目。但是当我运行它时，它将给出org.apache.kafka.common.errors.SerializationException：无法将类java.lang.Integer的键转换为类...

如何配置Kafka键SERIALIZER，对于有时键很长而其他时间键是String的情况？

我有kafka生产者配置，直到这次我将密钥作为String类型发送，并配置了SERIALIZER密钥，如下所示，configProps.put（ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG，...

向Kafka生产记录

我试图在不传递任何分区值的情况下向Kafka生成记录，但想发送标头，并且我在下面有重写方法来向Kafka生成记录，ProducerRecord（java.lang.String ...

Kafka Streams API：会话窗口不兼容的类型

我有以下代码段：groupedStream.windowedBy（SessionWindows.with（Duration.ofSeconds（config.joinWindowSeconds））。grace（Duration.ZERO））; KTable mergedTable = ...

Kafka如何向特定用户发送消息？

系统包含用户实体。每个用户都可以按类型获取消息。如何在卡夫卡组织这件事？我知道，我可以创建主题消息并通过关键的用户ID存储消息，但是如果有百万用户呢？ ...

ack如何在Kafka中用于发布/订阅？

使用发布/订阅如何确认消息？当消息以唯一组的形式发送给某些使用者时。这是否表示所有消费者都确认了消息或所有消息都得到了确认...

Kafka序列化器和模式注册

在我的生产者中，我有一个属性kafkaProducer.value.serializer，并设置为org.apache.kafka.common.serialization.StringSerializer。我只想知道架构注册表是否具有相同的用途或执行这些操作...

何时使用Kafka交易API？

我试图了解Kafka的事务性API。该链接定义了如下原子读取过程写入周期：首先，让我们考虑一下原子读取过程写入周期的含义。在...

如何从集合中有效地向Kafka生成消息

在我的Scala（2.11）流应用程序中，我正在使用IBM MQ中一个队列中的数据，并将其写入具有一个分区的Kafka主题。从MQ消耗数据后，消息有效负载就会得到...

Kafka Connect和自定义查询

我有兴趣在创建发票时使用Kafka Source JDBC连接器执行发布到Kafka。在源端，它分为2个表Invoice和InvoiceLine。 ...

充分利用kafka-node

我需要为我的项目使用什么正确的Kafka结构以及为什么的建议。我的项目Im正在创建投资机器人管理平台。非常高级-您可以编码...

如何检查Ruby-Kafka重试是否有效？

在文档中提到生产者重试以基于max_retries将消息发送到队列。因此，我关闭了Kafka，然后尝试了制作人。我收到此错误正在获取...

Kafka生产者回调异常

[当我们生成消息时，我们可以定义一个回调，该回调可能会发生异常：kafkaProducer.send（producerRecord，new Callback（）{

Kafka生产者回调专有

[当我们产生消息时，我们可以定义一个回调，该回调可能会发生异常：kafkaProducer.send（producerRecord，new Callback（）{public void onCompletion（...

如何使用点网在Kafka中生成墓碑Avro记录？

我的接收器属性：{“名称”：“ jdbc-oracle”，“配置”：{“ connector.class”：“ io.confluent.connect.jdbc.JdbcSinkConnector”，“ tasks.max”：“ 1” ，“主题”：“订单”，“ connection.url”：...

如何使用dotnet在Kafka中生成墓碑Avro记录？

我的接收器属性：{“名称”：“ jdbc-oracle”，“ config”：{“ connector.class”：“ io.confluent.connect.jdbc.JdbcSinkConnector”，“ tasks.max”：“ 1”， “ topics”：“ orders”，“ connection.url”：...

Kakfa重试概念-卡夫卡将停止哪些基础重试？

作为Kafka的新手，试图了解Kafka中的重试概念。什么基础的重试过程将完成？示例Retries参数我们设置为7。现在问题在这里，卡夫卡将是...

Apache Camel-Kafka组件-单一生产者多个消费者

[我正在创建两个Apache骆驼（蓝图XML）kafka项目，一个是kafka-producer，它接受请求并将其存储在kafka服务器中，另一个是kafka-consumer，它从...中拾取消息。

Kafka Producer超时异常：即使最大请求超时和正确的批处理大小，也是如此

[我们目前有大约80个应用程序（大约200个K8s副本）每天向kafka写入16-17百万条记录，其中一些记录由于超时和重新平衡而间歇性地失败...