-
107 votesanswersviews
控制台 生产环境 者中的领导者不可用Kafka
我正在尝试使用Kafka . 所有配置都正确完成但当我尝试从控制台生成消息时,我不断收到以下错误 WARN Error while fetching metadata with correlation id 39 : {4-3-16-topic1=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient) kafka版... -
2 votesanswersviews
Java中的 生产环境 者/消费者模式
我正在考虑如何在Java中实现 生产环境 者/消费者模式 . 假设我有3个线程和一个包含任务的List(比如它是大约5个任务) . 每个线程从列表中获取任务并同时执行它 . 我目前的方法是使用CountDownLatch int N = 3; CountDownLatch startSignal = new CountDownLatch(1); CountDownLatch doneSignal ... -
0 votesanswersviews
消费者 生产环境 者模式, 生产环境 者在重新触发之前等待所有消费者完成?
我试图在这种情况下(任何版本)找出Java的最佳方法来实现单个 生产环境 者多个使用者,其中我使用ExecutorService(优先,不需要),其中 生产环境 者需要“永远”运行,但每次都是运行时,它需要等待所有内容完全处理,例如所有消费者线程都已终止,队列为空,并且不会生成任何项目 . 生产环境 者也应该只以固定的间隔轮询其数据源 . 举个例子:每30分钟我希望我的 生产环境 者轮询其数据源... -
0 votesanswersviews
Kafka ssl Producer EOFException,同时来自Cloud Foundry的Producer.send
在Cloud Foundry中,我能够向非ssl url(“kafkaURL:9092”)生成消息 . 但它不适用于ssl url(“kafkaURL:9093”) . Kafka服务器版本0.10.0.1和客户端版本0.10.0.0 . 这是我使用的 properties : props.put(org.apache.kafka.clients.producer.ProducerConfig.B... -
4 votesanswersviews
自上次追加以来,Kafka制作人发送的消息到期时间为30003毫秒
我正在使用Kafka 0.10.1.1并编写测试 生产环境 者,但我在 producer.send onCompletion 回调中收到错误: producer.send(record, new Callback() { @Override public void onCompletion(RecordMetadata metadata, Exception e... -
2 votesanswersviews
AWS上的Kafka经纪人 - IP设置
我在EC2上安装了Kafka软件 . 我的问题是从AWS外部连接到代理 . 这一切都适合我 . 所以我可以启动代理,kafka-console-producer和consumer工作(来自同一台服务器) . 我有端口2181和9092向远程位置开放,朝向我想要使用 生产环境 者的地方 . 所以从我的开发(本地)机器..如果我做telnet 9092 - 它连接我 . 如果我尝试使用kafka-c... -
0 votesanswersviews
为什么kafka 0.10控制台 生产环境 者无法向kafka 0.9发送消息?
为什么kafka 0.10控制台 生产环境 者无法向kafka 0.9发送消息? 我在0.9版本(在服务器端)启动kafka控制台消费者 . 我在0.10版本(在客户端)启动kafka控制台 生产环境 者 . 然后我进入了 生产环境 者异常(下面) . 新制作人怎么可能无法向老消费者发送消息?是否有可能将新 生产环境 者设置为一种不推荐使用的模式,以便向旧 Kafka 发送消息? $ bin \ ... -
1 votesanswersviews
bin / kafka-console-producer.sh异常
当我键入此命令行时:bin / kafka-console-producer.sh --broker-list localhost:9092 - topic test 但是,最终结果会像这样返回: 没有回报,这是不寻常的 . 有人可以帮忙吗?先谢谢 . -
0 votesanswersviews
KAFKA REMOTE AWS consumer.poll
嗨,我一直在尝试学习KAFKA并与我的远程轮询器/消费者有问题 . 我在AWS EC2实例中使用私有和公共ip设置了KAFKA . 我的server.properties看起来像这样 . listeners = PLAINTEXT://172.31.31.58:9092 #AWS Private IP advertised.listeners = PLAINTEXT:// 35 . ?? . ??... -
9 votesanswersviews
生成消息时无法找到主题:UNKNOWN_TOPIC_OR_PARTITION
我有一个双节点kafka集群(EC2实例),其中每个节点都用作一个单独的代理 . 当我使用以下命令在leader实例上运行 生产环境 者时: kafka-console-producer.sh --broker-list localhost:9092 --topic test 我收到以下错误 . 测试消息[2017-01-09 13:22:39,483] WARN在获取具有相关ID 0的元... -
1 votesanswersviews
如何在Kafka 0.11中正确提交 生产环境 者并使用事务性消息?
我正在尝试Java中的Kafka Transnational制作人 . 喜欢 producer.initTransactions(); try { producer.beginTransaction(); producer.send(rec, new Callback() { public void onCompletion(Reco...