星星之火是从一个主题“一”中获取数据,处理它,并将其发送到同一个Kafka集群上的另一个名为“二”的主题。我使用kafka-console-producer.sh来编写主题"one“中的数据,使用kafka-console- and . am读取主题”2“中的数据。主题“一”和“二”各有两个分区。
现
我试着用这个代码用broker版本0.10测试kafka流。它只是一个简单的代码来打印一个主题的内容。还没什么大不了的!但是,由于某种原因,内存是不够的(VM中的10 VM内存)!守则:kafka-test-003.py: test with broker 0.10(new Spark Stream API)
How to