kafka-producer-api

首页 > TAG信息列表 > kafka-producer-api

java – 如何检查Kafka Server是否正在运行？

我想在开始生产和消费工作之前确保kafka服务器是否正在运行.它是在windows环境中,这是我的kafka服务器在eclipse中的代码… Properties kafka = new Properties(); kafka.setProperty("broker.id", "1"); kafka.setProperty("port", "9092"); kafka.setProperty("log.dirs&q

linux – 在kafka控制台上无法输入大小超过4095个字符的消息

我试图通过kafka控制台生产者发送消息.但我无法输入超过4095个字符的消息.试图搜索生产者或服务器中是否存在与此相关的任何属性但无效.甚至试图搜索是否存在任何特定于OS的限制或stdin字符限制但没有找到任何内容. 请帮助通过控制台生产者发送大量消息.解决方法:我发现了另一种方

Kafka无法从头开始阅读–Java

我是kafka的新手,并尝试使用kafka构建一个生产者 – 消费者应用程序.在这里,我能够向kalka发送消息,但是当我尝试使用消费者消费它时,它返回0条记录. 我检查了我的消费者组的偏移量,我可以看到偏移量等于日志长度是相同的(在我的情况下为1M – 与记录数相同). 如果我在创建我的消

使用Java更新kafka中特定主题的TTL

更新主题的TTL,以便记录在主题中保留10天.我必须为特定主题执行此操作,只需将所有其他主题TTL保持相同,当前配置,我必须使用java执行此操作,因为我正在通过Java将主题推送到kafka.我正在设置以下属性以将主题推送到kafka Properties props = new Properties(); props.put("bootstr

java – kafka生产者非常慢

我是卡夫卡的新人,我有一个我无法解决的问题. 我已经在我自己的计算机上安装了Kafka和Zookeeper(不是在Linux中),我创建了一个主题包含多个分区(在6到12个分区之间播放)的代理. 当我创建消费者时,他们完美地工作并且阅读速度很快,但是在引用制作人的时候,我创建了一个可以在许多网

java – Kafka Streams：如何更改记录时间戳(0.11.0)？

我正在使用FluentD(第12版稳定版)向Kafka发送消息.但是FluentD使用旧的KafkaProducer,因此记录时间戳始终设置为-1. 因此,当消息到达kafka时,我必须使用WallclockTimestampExtractor将记录的时间戳设置为时间点. 我真正感兴趣的时间戳是由流利的信息发送的： “timestamp”:”15078

如何找回Kafka生产者和消费者配置(Java API)？

用例如下. 我在Java代码中通过许多对象实例传递生产者或消费者引用.在其中一些我想对Kafka配置进行一些检查.这意味着我想回来,Kafka Producer / Consumer中存储了哪些有效的配置(包括默认值).我没有看到java docs中的anthing： > KafkaProducer> KafkaConsumer 那么,如何找回Kafka生