Apache Kafka

Apache Kafka

文章 164 浏览 73

Kafka Windows端Producer无法发送消息到服务器kafka

kafka开发环境搭建时,在windows下运行java项目,报:Unable to connect to zookeeper server within timeout: 6000,在windows下ping liunx地址是可…

归属感 2021-11-28 02:27:51 843 0

请用一句话概括scala、akka、kafka、hadoop、团队

1:一句话概括scala的核心优势? 2:一句话概括Akka的核心优势? 3:一句话概括Kafka的核心优势? 4:一句话概括hadoop的核心优势? 5:一句话概括团队协助的…

灵芸 2021-11-28 02:21:12 903 0

关于1.0最新版的kafka-consumer-perf-test.sh的问题

现在需要对kafka集群进行压力测试 查阅了很多资料 发现旧版的kafka-consumer-perf-test.sh可以设置线程数 采用同步异步传输等参数。而新版却没有找到…

霞映澄塘 2021-11-27 22:50:17 745 0

我想看Kafka生产者消费者模型学习这篇文章

@猪头三头猪 你好,想跟你请教个问题: 我看您写了一篇【Kafka生产者消费者模型学习】,点击之后没有阅读权限,请问如何能查看这篇文章? …

坐在坟头思考人生 2021-11-27 21:45:57 909 0

在哪修改“kafka-request.log”,"server.log"等日志文件的存储位置

我运行kafka和zookeeper,会在E盘根目录下生成kafaka-request.log,kafka-authorizer.log,controller.log,server.log,log-cheaner.log,state-change.lo…

怎言笑 2021-11-27 18:02:41 835 0

org.apache.spark.SparkException: Task not serializable

我在实现spark从kafka里读取数据,然后入Mongodb,出现以下的问题: org.apache.spark.SparkException: Task not serializable at org.apache.spark.…

本王不退位尔等都是臣 2021-11-27 16:10:43 719 0

请教kafka 启用多台consumer 问题?

@FrankHui 你好,想跟你请教个问题://多线程方式     public static void consumer(){         Properties props = new Properties();           pr…

夜司空 2021-11-27 09:57:44 723 0

在OpenSOC环境部署过程中,向storm提交拓扑时,报zookeeper错误信息,求助

运行 OpenSOC的示例程序 ,向storm中提交拓扑 出现如下错误log日志信息,程序不能正常运行 29246 [Thread-24-KafkaSpout] ERROR backtype.storm.util…

终陌 2021-11-27 06:57:34 688 0

flume+kafka 性能问题

应用场景: 在使用spoolDir作为flume source,kafka作为sink将文件内容缓存到kafka中。 问题: 发现flume + kafka在信息缓存的性能上不是很好,现在…

卸妝后依然美 2021-11-27 06:14:19 885 0

在同一个分区里的message的offset是不是一定会有序增1

如题,在同一个分区里的message的offset是不是一定会有序增1? 也就是说在同一分区里offset是不是一定 0 1 2 3 4 5 6这样下去?而不会出现0 1 3 4 5 …

无人问我粥可暖 2021-11-27 04:44:57 979 0

kafka 为何过段时间莫名其妙的停止服务了, 看了log 也找不出原因,哪位大神告诉我下

如题,看了,kafka的日志,也没有找到原因,有点急 …

猫烠⑼条掵仅有一顆心 2021-11-26 17:28:21 940 0

kafka0.8启动报错

@FrankHui 你好,想跟你请教个问题:我在Centos上安装单机kafka0.8的时候报错,向您请教下原因。 zookeeper启动时没有问题,当kafka启动时报如下的错…

瀞厅☆埖开 2021-11-26 12:25:52 743 0

kafka有非阻塞式收数据的方法吗

如题, 主要是写spout的时候阻塞接收貌似就执行不了fail和ack方法了 …

拥有 2021-11-26 05:27:52 829 0

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、测…

因为看清所以看轻 2021-11-26 03:32:56 838 0

kafka spout 性能

https://github.com/wurstmeister/storm-kafka-0.8-plus 有人做过kafkaspout的性能测试么?怎么配置会提高spout读取性能? …

心舞飞扬 2021-11-25 14:54:17 868 0
更多

推荐作者

苦中寻乐

文章 0 评论 0

lueluelue

文章 0 评论 0

嗼ふ静

文章 0 评论 0

王权女流氓

文章 0 评论 0

与花如笺

文章 0 评论 0

残酷

文章 0 评论 0

    我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
    原文