apache-kafka

英文: RecordTooLargeException in kafka 问题 以下是出现RecordTooLargeException异常的Kafka发布代码。 尝试了在stackoverflow上...

英文: How to convert the following piece of java to kotlin? 问题 consumer.commitAsync(mapOf(k to current...

英文: How to use multiple transformers using the same topic for kafka streams? 问题 我需要使用多个转换器解析 Kafka 上...

英文: Need suggestion regarding Spring Boot Kafka Stream Binder Application error 问题 我试图从 https://clou...

英文: Kafka streams aggregation RecordTooLargeException 问题 尝试使用5分钟的滚动窗口从单个流中聚合数据。最初运行正常，能够打印出聚合的记录。使用J...

英文: Spring Boot for Kafka - Multiple KafkaStreams config in one app 问题 在 Spring 中，对于 Kafka Streams，我...

英文: Creating ProtoBuf object schema for Kafka usage 问题 I am using ProtoBuf over Kafka. We are creati...

英文: Can I have an Avro Schema with an enum that includes values as enum members? 问题 这是我想转换为Avro模式的Ja...

英文: My FlinkKafkaProducer011 needs fewer arguments than is supposed to 问题 I’m having difficulties wi...

英文: Kafka Java Producer is not able to send message to kafka instance 问题 我正在运行一个在Docker容器中的Kafka实例，使...