apache-kafka
-
卡夫卡消费者轮询超时 我正在与Kafka合作,并试图从中消耗数据。从下面一行开始,我可以轮询来自Kafka的数据。 我的问题是,与我提供超时相比,我通过提供超时获得的好处是什么。将要运行生产的系统的最佳做
-
-
即使在 Kafka 中进行轮询后,也不会发生分区的当前分配 我有Java 8应用程序使用Apache Kafka 2.11-0.10.1.0。我需要使用该功能来存储来自分区的旧消息。但是,我每次尝试时都会遇到异常。这是我的类,负责将主题发送到指定的时间戳:
-
将自定义 Java 对象发送到 Kafka 主题 我有我的自定义Java对象,并希望在内置序列化中利用JVM将其发送到Kafka主题,但序列化失败并出现以下错误 org.apache.kafka.common.errors.SerializationException:无法将类 com.spring.kafka.Payload 的值转换为
-
何时使用 ConcurrentKafkaListenerContainerFactory? 我是kafka的新手,我浏览了,但我什么也听不懂。有人可以解释一下何时使用这个类吗?我已经使用了该类,但我看到在我当前的项目中被使用。请解释它的作用。
-
卡夫卡 - 制片人致谢 我在视频教程中看到,当生产者发布消息时,Kafka Broker支持3种类型的确认。 0 - 火与忘 1 - 领导者 Ack 2 - 所有经纪人的 Ack 我正在使用Kafka的Java API来发布消息。这是必须使用特定于每个代理的 serv
-
在将消息传递给消费者之前如何过滤消息? 我正在与Kafka一起创建一个潜在客户和事件管理系统。问题是我们得到了许多虚假的线索(广告)。我们的系统中也有许多消费者。在去消费者之前,有没有过滤广告?我的解决方案是将所有内
-
将 kafka 与 jpa 一起使用时的良好做法 我目前在一个使用JPA和Kafka的项目中。我试图找到一套结合这些操作的良好实践。 在现有代码中,生产者与jpa用于同一事务中,但是,从我所读到的内容来看,它们似乎没有共享事务。 这是
-
Kafka 错误反序列化分区的键/值 我有一个集成测试,当我发送到没有键的Kafka主题时,该测试会通过。但是,当我添加一个键时,我开始收到序列化错误。 与往常一样,任何帮助将不胜感激。 所有要重现的代码均可在
-
标签