我用Java生产者API向Kafka V.0.8发送字符串消息。如果消息大小约为15 MB,我将得到一个MessageSizeTooLargeException。我尝试将message.max.bytes设置为40 MB,但仍然会遇到异常。小消息没有问题。我能做些什么来摆脱这个异常呢?217 failed due to [datasift,0]: kafka.common.MessageSizeTooLargeExceptio
我正在使用kafka向消费者发送消息。但是,由于某些原因,当我使用producer.send(record, new MyProducerCallback());将记录发送到一个主题中时,该主题的使用者不会收到该记录。但是,当我使用RecordMetadata m = producer.send(record).get();发送记录时,记录会完美地到达消费者那里。回调方法曾经有效,但现在不起作用了。