-
2 votesanswersviews
Publisher如何在Apache Kafka中将消息发布到主题？
我是Apache Kafka的新手 . 我不了解Apache Kafka中主题和分区的解剖结构以及Producer将数据推送到分区的方式 . 考虑一个场景，我有两个 生产环境 者PR1，PR2和三个经纪人B1，B2，B3 . 并且一个主题T1与三个分区为P1，P2，P3分成三个代理 . 现在，第一个 生产环境 者PR1与Zookeeper协调，找到Broker并将消息推送到T1-P1，并将消息推送... -
2 votesanswersviews
Kafka和Pyspark整合
我在大数据中天真，我试图将kafka连接到火花 . 这是我的 生产环境 者代码 import os import sys import pykafka def get_text(): ## This block generates my required text. text_as_bytes=text.encode(text) producer.produce(...