在我的应用程序中,我们使用Kafka高级用户,如果生产者和使用者使用java对数据进行压缩和解压缩,它将使用解压缩数据,而不会出现任何问题。如果生产者使用librdkafka C++ API进行压缩(无论是snappy还是GZIP),会发生什么?java使用者是否像上面提到的那样透明地解压缩。消费者端的获取大小会发生什么?我们是否必须显式地解压缩来自生产者的压缩数据(假设这里使用的是librdkafka C++ API )。我在想,在发生压缩的情况下,高级别的使用者可能无法在生产者端使用
我正在尝试使用IBM消息中心创建生产者和消费者应用程序。config, null, new StringSerializer(Encoding.UTF8))) ....对于使用者,我使用类似的配置属性。使用者的其余代码:
using (var consumer = new Consumer<Null, string>(config, null, new StringDeserializer(Encoding.UTF8我得到的日