[mw_shl_code=shell,true][2019-05-21 09:45:04,120] WARN Attempting to send response via channel for which there is no ope ...

ighack 2019-5-23 4 21758

现在做个小项目。需要把kafka的数据采集到hdfs存储。数据从本地由flume采集到了kafka中。是不是kafka中的 数据只能通过消费者消 ...

yunge2016 2017-7-1 17 30935

用java写了个kafka producer小程序，启动的时候报错，topic已经创建成功了，但是消息发布不了 急求大神帮忙看看 16/12/1 ...

m331283153 2016-12-16 2 13343

[2019-08-07 19:36:46,248] ERROR [Replica Manager on Broker 3]: Error processing append operation on partition __consumer ...

ighack 2019-8-8 0 6202

我现在做一个假设消费程序开了A B两个线程。每一个线程都是一个完整的Consumer实例。每个实例一次取10条消息 A 取了1-10 B 取 ...

ighack 2019-6-28 2 6629

我的kafka集群运行一段时间以后就会出现问题 isr就会不正常。正常情况应该是三台，但一段时间以后就会掉一台 而且掉的这一台机 ...

ighack 2019-5-21 9 7049

用启动消费者的方式，同时创建了一个新版消费组 kafka manager type显示为KF 尝试用命令删除无反应 kafka-consumer-groups.sh ...

evababy 2018-2-24 3 21648

上午发了一个帖子，咨询如何安装kafka，安装的过程中遇到了很多的错误，网上也没有一个很完整的帖子说出来怎么安装。 首先介 ...

zj220223 2017-6-22 2 40498

环境：jar:spark-streaming-kafka-0-10_2.11 spark:2.1.0 kafka:0.10.0 scala:2.11.8 代码如下：[mw_shl_code=scala,tru ...

醉半城 2017-7-6 12 21953

kafka的序列化 key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer value.deserializer = c ...

jinwensc 2018-5-28 6 11894

我现在生产数据没问题，但是为什么消费报认证错误？？？？？？，在线等，比较着急

逆光之处是快乐 2018-5-19 3 6459

微信搜索关注：若泽大数据，有精美课程和定时推送技术博客，qq交流群：707635769，一起交流，一起进步 CentOS7中安装LZO ...

ruozedashuju 2018-4-8 0 7481

微信搜索关注：若泽大数据，有精美课程和定时推送技术博客，qq交流群：707635769，一起进步 转载主要优化原理和思路kafka ...

ruozedashuju 2018-4-7 0 6780

引入Kafka的时候，发现引入不了。在maven里已经添加依赖了。报错Cannot resolve symbol KafkaUtils

zqf 2018-3-5 2 9369

kafka的jdbc connector可以增量的从一个关系型数据库导出数据到kafka中吗？当数据库中数据全部导完后，如果又新增加数据到数据库 ...

zstu 2018-1-11 4 5928

本人刚接触Kafka, 是个小白，求大神帮忙解答，谢谢！ 应用场景： 我需要从Oracle中不断把业务数据导入到Kafka, 并写入HBase ...

harley 2017-1-8 6 41002

初学kafka，想咨询下kafka 消息有序的问题， 请教下 这个有序是不是指单独的partition是有序的 但是整个topic有多个分区的话 ...

Wyy_Ck 2017-6-15 6 7053

[root@master bin]# ./kafka-console-consumer.sh --zookeeper master:2181 --topic shuaigeck --from-beginning [2017-09-07 ...

Wyy_Ck 2017-9-9 2 15900

怎么查看kafka集群中所有的broker节点 扩容的时候，怎么知道新启动的节点已经加入到集群了

arsenduan 2015-3-6 2 166360

我用下面的代码来消费kafka的数据，但一直停在ConsumerRecords records = consumer.poll(100);这一行。没有消费数据，也不报错 ...

zstu 2017-5-9 19 47545

有人在生产上通过kafka直接追加数据hdfs吗，不通过storm

ananan36 2017-7-22 1 5976

目前我采用flume监听端口去获取发送过来的syslog，然后发送到kafka，但是根据需求，我还得把数据再通过udp协议发送到某个端口， ...

cyb1994 2017-7-10 6 18938

使用命令查看kafka LOG数据： /kafka-run-class.sh kafka.tools.DumpLogSegments ...

Wyy_Ck 2017-6-30 5 8702

自己学习 做了个 log4j-flume-kafka 发现linux(在虚拟机上)上用自带的可消费javaDemo里面的log4信息,通过kafka-clients 却无法消 ...

gdz911 2017-7-2 1 9628

阿里云kafka集群有两个网卡，集群间broker交互采用内网，但是数据需要从外网producer发送进去，那我需要怎么设置才可以实现外网 ...

ltne 2017-6-30 2 10764

kafka集群安装在阿里云，我在本地往集群发送数据，producer设置参数 properties.put("bootstrap.servers", "master:9092"); ...

ltne 2017-6-29 4 52932

一直没有搞明白 zookeeper 下kafka目录是什么意思 请大神指点： [mw_shl_code=shell,true]zk: localhost:2181(CONNECTED) 13] ...

Wyy_Ck 2017-6-25 4 8460

kafka producer： [mw_shl_code=shell,true]bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test ss ...

Wyy_Ck 2017-6-20 6 12883

求大神指教一下

Hentai 2016-9-26 5 46363

各位大侠 我的生产环境是三台集群+cdh5.9，操作系统是ubuntu14.04 64位 我想安装kafka，在网上搜了一下方法，有手动 ...

zj220223 2017-6-22 2 7609