用户组:游客
问题导读 1.Hadoop3.3支持JDK哪个版本? 2.SCM是什么? 3.YARN应用程序做了哪些改进? 4.整合腾讯云实现了什么文件系统? ...
我用下面的代码来消费kafka的数据,但一直停在ConsumerRecords records = consumer.poll(100);这一行。没有消费数据,也不报错 ...
现在做个小项目。需要把kafka的数据采集到hdfs存储。数据从本地由flume采集到了kafka中。是不是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要对外网提供服务。但是端口映射不出去,外网无法收发消息 advertised.host.name = ip 不行。 adver ...
kafka运行如下命令:kafka-server-start.sh config/server.properties & 其中配置如下:zookeeper.connect=192.168.2.10:2181/k ...
我有一个0.10的kafka集群,通过端口映射到外网,有9个生产者程序在外网向集群发布消息,开始我用kafka-client0.10的jar包时,有3 ...
我的kafka集群运行一段时间以后就会出现问题 isr就会不正常。正常情况应该是三台,但一段时间以后就会掉一台 而且掉的这一台机 ...
我想实现下面功能: 我有一个文本型的第三方数据库,有一个时间戳字段,我想通过kafka增量的从这个库中读取新数据。一次性的读 ...
用了这么长时间的kafka了,有些问题今天还是问问吧。 kafka创建节点我知道, 删除节点也有个命令可以删除: kafka-run-class. ...
今天突然遇见了这个问题 kafka-console-producer --broker-list localhost:9092 --topic mykafka 就执行了这个命令 ...
1、config/consumer.properties 这个文件有什么用?能管的住group吗? 2、而且,我消费代码似乎写什么group都可以哦,也就是 ...
初学kafka,想咨询下kafka 消息有序的问题, 请教下 这个有序是不是指单独的partition是有序的 但是整个topic有多个分区的话 ...
kafka的序列化 key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer value.deserializer = c ...
通过HTTp协议或者长连接、队列,这几种方式都分别如何将数据放到生产者里面,然后send出去。有没有具体的代码或者方案,求大神帮 ...
kafka producer: [mw_shl_code=shell,true]bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test ss ...
目前我采用flume监听端口去获取发送过来的syslog,然后发送到kafka,但是根据需求,我还得把数据再通过udp协议发送到某个端口, ...
本人刚接触Kafka, 是个小白,求大神帮忙解答,谢谢! 应用场景: 我需要从Oracle中不断把业务数据导入到Kafka, 并写入HBase ...
使用命令查看kafka LOG数据: /kafka-run-class.sh kafka.tools.DumpLogSegments ...
1、看下边两个Api是什么区别??同样是producer import kafka.javaapi.producer.producer import org.apache.ka ...
问题导读: 1.在Kafka中使用SQL的流程是什么?2.怎样配置Kafka,使得在Kafka中使用SQL?3.在Kafka中使用SQL有哪些注意事项? ...
我从Apache官网下载kafka_2.11-0.9.0.1.tgz,或自己编译kafka-0.9.0.1-src,然后自己虚拟机上部署单节点的Kafka时, [mw_shl_co ...
我用storm应用消费了kafka的消息,奇怪的是处理成功了,但kafka的消息却能被重复消费,我把storm应用重启后,下次还是能再次读取 ...
例如设置成producer每5分钟发送一次数据,求各位指点
我用kafka+storm搭了一个平台,遇到一个丢数据的难解问题,求各位帮忙 发送到kafka的消息条数为552860条, 在storm中调用kafka ...
求大神指教一下
【背景】 公司kafka集群,有几台机器被回收,由于维护疏忽,并没有做Partition转移,目前通过manager界面观察业务生产、消费正 ...
本人刚学习kafka,问一下producer能不能获取到consumer处理之后的返回值? 如果不能的话,类似这种需要回传的需求是不是不能 ...
刚接触kafka,版本0.8.2 测试过程中存在几个疑问,望解答。 1、创建一个topic后,用JAVA程序正常接受,如何设置消息的超时时 ...
最近需要对kafka集群做流量限制,有大神知道相关的设置么。另外安全方面如何设置读取权限,现在所有用户都能读取,想改进下。
[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 ...
本版积分规则 发表帖子
查看 »