我想在Java中创建kafka主题。我有一个来自stackoverflow的示例代码。但问题是我不能导入ZKStringSerializer$和ZkUtils。我有所有的maven依赖项。原因何在?下面是代码: import kafka.admin.AdminUtils;
import kafka.utils.ZKStringSerializer$;
import kafka.utils.ZkUtils;
import org.I0Itec.zkclient.ZkClient;
import org.I0Itec.zkclient.ZkConnection;
public class C
我想使用Kafka绑定的testcontainers来集成测试我的应用程序。
在下面的场景中,测试设置永远不会通过waitForMessagesToBeDelivered,它将永远等待在收到消息后创建实体。在我的理解中,它应该通过Kafka传递两个消息,这两个消息应该被MyConsumer接收,然后应该创建两个MyEntity,这应该会增加myEntityRepository.count()返回的值。
在我为其创建此再现设置的类似场景中,接收到两条消息中的一条,并为其创建一个实体。
@Service
public class MyConsumer {
private final sta
关于卡夫卡,你有没有遇到过类似的问题?我得到这个错误:Too many open files。我也不知道原因。以下是一些日志:
[2018-08-27 10:07:26,268] ERROR Error while deleting the clean shutdown file in dir /home/weihu/kafka/kafka/logs (kafka.server.LogD)
java.nio.file.FileSystemException: /home/weihu/kafka/kafka/logs/BC_20180821_1_LOCATION-87/leader-epoch-