基于特定代理的Kafka主题创建
共有1个答案
在创建主题时，您可以只指定分区和副本的数量，并让Kafka分发它们。或者您可以直接指定分配-哪个分区和副本放在哪里。
如果您使用的是作为kafka的一部分的kafka-topics.sh脚本，那么您可以对它使用--replica-assignment选项。例如：
bin/kafka-topics.sh --create --zookeeper localhost:2181 --topic topic1 --replica-assignment 0:1:2,0:1:2,0:1:2
如果主题已经存在，则可以使用kafka-reassign-partitions.sh工具更改分配。
-
其中一个Kafka流应用程序在Kafka代理和消费者端产生了大量未知生产者ID错误。 流配置如下： 消费者方面的错误： 这背后的原因是什么？
-
我有这样的拓扑： 拓扑中最后提到的源是每个应用程序实例的特定主题。我希望该主题仅由该实例处理。此主题的数据由前一个处理器推送，基于哪个实例必须处理该消息。 但是一旦流启动，它会尝试将实例特定的主题分区也分配给其他实例。我们可以在Kafka流中实现这个要求吗？ 我希望一个主题仅由特定实例处理。
-
本文向大家介绍Spring基于ProxyFactoryBean创建AOP代理，包括了Spring基于ProxyFactoryBean创建AOP代理的使用技巧和注意事项，需要的朋友参考一下 Spring 通知类型 通过前面的学习可以知道，通知（Advice）其实就是对目标切入点进行增强的内容，Spring AOP 为通知（Advice）提供了 org.aopalliance.aop.Advice 接
-
我正在使用spring-boot 2.3.9和spring-security以及keycloak 12.0.4。 和我的服务bean创建配置 编辑：这可能与Spring-Cloud-Starter-Sleuth有关。如果我移除这个依赖关系，所有的事情就会像预期的那样工作。但我也需要侦探。
-
我对任何逻辑都是新手，希望执行以下任务。我在GIS环境中有几种类型的固定代理，希望通过网络将它们连接起来。连接的条件如下：让代理类型A有4个代理，代理类型B有20个代理。我想根据最短（直线）距离连接B和A。也就是说，B型代理将连接到最近的A型代理。 非常感谢。
-
问题内容： 我是Kafka的新手，正在使用新的KafkaProducer和KafkaConsumer，版本：0.9.0.1 在创建特定主题之后，java中是否有任何方法可以更改/更新特定主题的分区数。 我没有使用Zookeeper创建主题。当发布请求到达时，我的KafkaProducer会自动创建主题。 如果还不够，我还可以提供更多详细信息 问题答案： 是的，有可能。您必须在中访问scala类以添
-
我有一个@KafkaListener方法来获取主题中的所有消息，但对于@Scheduled方法工作的每个间隔时间，我只获取一条消息。如何一次从topic获取所有消息？ 这是我的课； 这是我在应用程序中的Kafka属性。yml； 还有我的KafkaConfiguration课程；