Open HuBlanker opened 2 years ago
Configuration config = { { "metadata.broker.list", kafka_servers} }; Producer pp(config); MessageBuilder builder("***"); builder.partition(8); builder.payload("1999"); pp.produce(builder); pp.flush(); my code is like this.
Configuration config = { { "metadata.broker.list", kafka_servers} }; Producer pp(config); MessageBuilder builder("***"); builder.partition(8); builder.payload("1999"); pp.produce(builder); pp.flush();
producer success. consumer got one message. but it is null.
consumer is kafka shell consumer.
thanks for you time.
Same here. Did you find a way to solve this problem?
Configuration config = { { "metadata.broker.list", kafka_servers} }; Producer pp(config); MessageBuilder builder("***"); builder.partition(8); builder.payload("1999"); pp.produce(builder); pp.flush();
my code is like this.producer success. consumer got one message. but it is null.
consumer is kafka shell consumer.
thanks for you time.