我使用spring kafka (KafkaTemplate)来发送字符串消息。但是为了使它与旧代码兼容，我需要在消息中附加额外的CorrelationId。所以我创建了ProducerRecord对象，将我的消息作为它的值，并在它的HeaderRecord中设置CorrelationId。);
键和值序列化程序被设置为StringSerializer，但是about代码失败，说明ProduderRecord不是String或Stri
浏览 6提问于2017-12-12得票数 0
回答已采纳
我正在使用一个非事务性生产者，并试图了解在成功/失败场景中如何处理回调。然后，我通过向kafka模板提供一个不存在的主题名来模拟一个失败，这次似乎在侦听器容器线程中执行回调(“未能发送”消息)，然后是侦听器
浏览 7提问于2020-03-15得票数 0
回答已采纳
通过使用kafka生成器将文件转换为字节数组，我将发送一个文件作为消息。我想知道是否有一种方法可以在发布消息时添加自定义标头？
浏览 4提问于2015-03-13得票数 33
回答已采纳
1回答
.ok() } id, );
final ProducerRecord<String, Object> producerR
浏览 4提问于2022-04-20得票数 0
相关：val producer : KafkaProducer=
浏览 5提问于2017-09-18得票数 0
回答已采纳
我通过以下代码向Kafka broker实例发送Apache格式化消息：
ProducerRecord<String, byte[]> producerRecord = new ProducerRecord中结束，并被处理成一个InfluxDB。我使用类似的代码发送字符串格式的消息。这段代码是在不产生信息信息的情况下执行的。类中记录的。我需要处理这些消息
浏览 2提问于2021-03-31得票数 0
回答已采纳
我在使用kafka的Java项目中遇到了一个问题。我有一个价格数据库，当我删除一个价格时，我想向kafka发送一条包含所有价格信息的消息。在我的Endpoint.java中，我有一个用于deleteById的方法(IdPrix)： @RequestMapping(value =<String, Price> producerRecord = new P
浏览 0提问于2020-04-30得票数 2
弹簧-引导2.X
当生产者发送Kafka消息时，定制的DTO(或POJO)通过JSON String转换为ObjectMapper.writeValueAsString(custo
浏览 1提问于2021-04-08得票数 0
回答已采纳
为了根据配置向不同的Kafka消息发送数据，我想使用Spring服务： { ProducerRecord<String, Object> record = new ProducerRecord<String, Object>
浏览 6提问于2021-02-15得票数 2
回答已采纳
2回答
该模式是在该主题的模式注册表中设置的，我已经使用Maven Avro插件从相关的AVSC文件创建了POJO (LoanInitiate)。使用以下内容发送时，没有问题： import org.springframework.messaging.Message;
浏览 293提问于2021-04-23得票数 1
2回答
我试图在不传递任何分区值的情况下向Kafka生成一条记录，但是我希望发送一个标头，并且我有下面的构造函数方法来向Kafka生成记录：创建要发送到指定主题和分区的记录ProducerRecord
浏览 1提问于2020-05-19得票数 2
回答已采纳
Java应用程序向Kafka集群发送或发布消息。发送记录的代码如下所示。由于这个应用程序向kafka发送了大量的记录消息，因此调试起来有点困难。但我看到一些消息没有发送给kafka，因为我在kafka broker subscriber中没有看到相同主题的一些消息。所以看起来这条管道中有一些数据泄漏。它返回的结果是false。所以我很困惑到底哪里存在泄漏。是否无法
浏览 29提问于2019-09-20得票数 0
在中，为了进行模式检查并将数据放入到kafka主题中，我们所需要做的就是使用kafka客户端ProducerRecord对象和avro对象。但是在中，我们需要重写卡夫卡出口的"ProducerRecord<byte[]，byte[]>序列化“方法。这将导致以下错误。Caused by: org.apache.kafka.common.errors.SerializationException:
浏览 6提问于2020-06-22得票数 0
回答已采纳
我试图用Avro序列化程序和模式注册表向Kafka发送一个对象。 Properties props = new Properties(); producer.send(record);
我假设模式是从注册表中“幕后”读取的，并且对象(我是否必须显式读取模式并发送一个GenericRecord？:不支持Avro
浏览 6提问于2017-10-31得票数 1
我有一个非常简单的kafka制作人，它使用以下方法发送数据：producer.send(producerRecord);create stream m
浏览 1提问于2020-05-02得票数 1
回答已采纳
例如，我有一个雇员POJO： private int id;}ProducerRecord<Integer, Employee> record = new ProducerRecord<>("topic",employee.getId(), emp
浏览 0提问于2019-03-12得票数 2
回答已采纳
我正试图写一个从星火到卡夫卡的DataFrame，却找不到任何解决办法。你能告诉我怎么做吗？= new ProducerRecord(topicc, activityDF)
}
类型不匹配；已发现: org.apache.kafka.clients.producer.ProducerRecord org.apache.<em
浏览 3提问于2017-04-17得票数 0
回答已采纳
我正在使用Scala中的0.9KafkaJava客户机。但是，未键的ProducerRecord会出现类型错误。scala> val unkeyedRecord = new ProducerRecord("topic", "value") kafkaProducer.s
浏览 1提问于2016-01-29得票数 4
回答已采纳
3回答
| 的所有都显示ProducerRecord的键/值对不仅具有相同的类型(所有示例都显示为<String,String>)，而且具有相同的值。例如：但在Kafka文档中，
浏览 20提问于2016-11-30得票数 116
回答已采纳
;public RequestReplyFuture<ItemId, MessageBDto, MessageBDto> sendAndReceiveMessageB(MessageBDtoKey=ItemId、Value=MessageBDto并在侦听器中接收密钥吗？侦听器似乎没有得到键和/或它似乎是MessageBDto的另一个实例。
浏览 1提问于2020-02-24得票数 1
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
