用户组:游客
[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 ...
现在做个小项目。需要把kafka的数据采集到hdfs存储。数据从本地由flume采集到了kafka中。是不是kafka中的 数据只能通过消费者消 ...
用java写了个kafka producer小程序,启动的时候报错,topic已经创建成功了,但是消息发布不了 急求大神帮忙看看 16/12/1 ...
[2019-08-07 19:36:46,248] ERROR [Replica Manager on Broker 3]: Error processing append operation on partition __consumer ...
我现在做一个假设消费程序开了A B两个线程。每一个线程都是一个完整的Consumer实例。每个实例一次取10条消息 A 取了1-10 B 取 ...
我的kafka集群运行一段时间以后就会出现问题 isr就会不正常。正常情况应该是三台,但一段时间以后就会掉一台 而且掉的这一台机 ...
用启动消费者的方式,同时创建了一个新版消费组 kafka manager type显示为KF 尝试用命令删除无反应 kafka-consumer-groups.sh ...
上午发了一个帖子,咨询如何安装kafka,安装的过程中遇到了很多的错误,网上也没有一个很完整的帖子说出来怎么安装。 首先介 ...
环境: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 ...
kafka的序列化 key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer value.deserializer = c ...
我现在生产数据没问题,但是为什么消费报认证错误??????,在线等,比较着急
微信搜索关注:若泽大数据,有精美课程和定时推送技术博客,qq交流群:707635769,一起交流,一起进步 CentOS7中安装LZO ...
微信搜索关注:若泽大数据,有精美课程和定时推送技术博客,qq交流群:707635769,一起进步 转载主要优化原理和思路kafka ...
引入Kafka的时候,发现引入不了。在maven里已经添加依赖了。报错Cannot resolve symbol KafkaUtils
kafka的jdbc connector可以增量的从一个关系型数据库导出数据到kafka中吗?当数据库中数据全部导完后,如果又新增加数据到数据库 ...
本人刚接触Kafka, 是个小白,求大神帮忙解答,谢谢! 应用场景: 我需要从Oracle中不断把业务数据导入到Kafka, 并写入HBase ...
初学kafka,想咨询下kafka 消息有序的问题, 请教下 这个有序是不是指单独的partition是有序的 但是整个topic有多个分区的话 ...
[root@master bin]# ./kafka-console-consumer.sh --zookeeper master:2181 --topic shuaigeck --from-beginning [2017-09-07 ...
怎么查看kafka集群中所有的broker节点 扩容的时候,怎么知道新启动的节点已经加入到集群了
我用下面的代码来消费kafka的数据,但一直停在ConsumerRecords records = consumer.poll(100);这一行。没有消费数据,也不报错 ...
有人在生产上通过kafka直接追加数据hdfs吗,不通过storm
目前我采用flume监听端口去获取发送过来的syslog,然后发送到kafka,但是根据需求,我还得把数据再通过udp协议发送到某个端口, ...
使用命令查看kafka LOG数据: /kafka-run-class.sh kafka.tools.DumpLogSegments ...
自己学习 做了个 log4j-flume-kafka 发现linux(在虚拟机上)上用自带的可消费javaDemo里面的log4信息,通过kafka-clients 却无法消 ...
阿里云kafka集群有两个网卡,集群间broker交互采用内网,但是数据需要从外网producer发送进去,那我需要怎么设置才可以实现外网 ...
kafka集群安装在阿里云,我在本地往集群发送数据,producer设置参数 properties.put("bootstrap.servers", "master:9092"); ...
一直没有搞明白 zookeeper 下kafka目录是什么意思 请大神指点: [mw_shl_code=shell,true]zk: localhost:2181(CONNECTED) 13] ...
kafka producer: [mw_shl_code=shell,true]bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test ss ...
求大神指教一下
各位大侠 我的生产环境是三台集群+cdh5.9,操作系统是ubuntu14.04 64位 我想安装kafka,在网上搜了一下方法,有手动 ...
本版积分规则 发表帖子
查看 »