Kafka Windows端Producer无法发送消息到服务器kafka
kafka开发环境搭建时,在windows下运行java项目,报:Unable to connect to zookeeper server within timeout: 6000,在windows下ping liunx地址是可…
请用一句话概括scala、akka、kafka、hadoop、团队
1:一句话概括scala的核心优势? 2:一句话概括Akka的核心优势? 3:一句话概括Kafka的核心优势? 4:一句话概括hadoop的核心优势? 5:一句话概括团队协助的…
关于1.0最新版的kafka-consumer-perf-test.sh的问题
现在需要对kafka集群进行压力测试 查阅了很多资料 发现旧版的kafka-consumer-perf-test.sh可以设置线程数 采用同步异步传输等参数。而新版却没有找到…
在哪修改“kafka-request.log”,"server.log"等日志文件的存储位置
我运行kafka和zookeeper,会在E盘根目录下生成kafaka-request.log,kafka-authorizer.log,controller.log,server.log,log-cheaner.log,state-change.lo…
org.apache.spark.SparkException: Task not serializable
我在实现spark从kafka里读取数据,然后入Mongodb,出现以下的问题: org.apache.spark.SparkException: Task not serializable at org.apache.spark.…
请教kafka 启用多台consumer 问题?
@FrankHui 你好,想跟你请教个问题://多线程方式 public static void consumer(){ Properties props = new Properties(); pr…
在OpenSOC环境部署过程中,向storm提交拓扑时,报zookeeper错误信息,求助
运行 OpenSOC的示例程序 ,向storm中提交拓扑 出现如下错误log日志信息,程序不能正常运行 29246 [Thread-24-KafkaSpout] ERROR backtype.storm.util…
flume+kafka 性能问题
应用场景: 在使用spoolDir作为flume source,kafka作为sink将文件内容缓存到kafka中。 问题: 发现flume + kafka在信息缓存的性能上不是很好,现在…
在同一个分区里的message的offset是不是一定会有序增1
如题,在同一个分区里的message的offset是不是一定会有序增1? 也就是说在同一分区里offset是不是一定 0 1 2 3 4 5 6这样下去?而不会出现0 1 3 4 5 …
kafka0.8启动报错
@FrankHui 你好,想跟你请教个问题:我在Centos上安装单机kafka0.8的时候报错,向您请教下原因。 zookeeper启动时没有问题,当kafka启动时报如下的错…
kafka-python通过Snappy压缩访问时,报Snappy codec is not available错误
1、测试环境: CentOS6.5_64位、JDK1.7、kafka版本为:kafka_2.9.2-0.8.2.2,zookeeper版本为:zookeeper-3.4.6, kafka-python-0.9.4 。 2、测…
kafka spout 性能
https://github.com/wurstmeister/storm-kafka-0.8-plus 有人做过kafkaspout的性能测试么?怎么配置会提高spout读取性能? …