=3sh kafka-topics.sh --bootstrap-server localhost:9092 --topic test --create replication-factor当我的控制台使用者开始工作时,会发生以下错误:
org.apache.kafka.common.errors.NotEnoughReplicasException: The size of the currentthe min.isr requirement of 3 for parti
我们正在使用MirrorMaker备份主题。我们注意到,与源集群相比,由Kafka应用程序创建的重新分区主题在目标集群中的大小似乎在不断增加。根据org.apache.kafka.streams.kstream.KStream#repartition()的文档,这是有意义的
Similar to auto-repartitioning, the换句话说,由于在目标集群中没有运行Kafka流应用程序,
我一直试图将数据从SQL server (启用更改跟踪)加载到Kafka,以便一个或多个系统(报表、其他DB等)能够使用这些数据。根据我发现的信息(在debezium论坛上),将为每个表创建一个主题-->它是否与kafka sql server连接器的工作方式相同?我在分布式模式下配置了连接,让kafka运行在多个服务器上,我们需要在每台服务器上运行连接吗?