生产过程中的问题:
我创建了有200个partition的topic,向Kafka中写数据的时候,只想这200中的部分写数据,没有全部都写,这是为什么呀?
消费过程中的问题:
命令一:
kafka-console-consumer.sh --bootstrap-server xxxx.xx.xx.xxx:9092 --topic test_topic --max-messages 10 --from-beginning **--partition 145**
命令二:
kafka-console-consumer.sh --bootstrap-server xxxx.xx.xx.xxx:9092 --topic test_topic --max-messages 10 --from-beginning
我分别用命令一个命令二区执行,命令一加上具体是哪个partition,这种方式可以正常消费。
但是如果我用命令二,执行之后一值处于运行中,没有结果输出,这又是什么原因呀?
大神,求指教。
1、你发送了多少消息,没有全写?
2、命令二一直处于运行中,那么如果你用生产者继续发消息,它能拿到消费吗?
你的答案