我对spring kafka broker故障转移机制持怀疑态度。我通过主动关闭代理来检查，我一直收到这些“无法建立到节点1的连接。代理可能不可用”的警告，只要代理关闭就会不断发出警告。我想要一个支持文档来了解它是否会由API本身自动发生？
浏览 117提问于2020-04-27得票数 0
)，会出现非常奇怪的情况。上面这两个花边新闻似乎暗示，通过使用流监控器和跳过元素，我们最终可能会遇到这样一种情况，即可提交的偏移量不再与每个Kafka消息生成的Done一致。例如:如果我们流式传输1、2、3、4并将1、2和4映射到Done，但在3上抛出异常，那么我们有3个Done和4个可提交的偏移量？
这是正确的/预期的吗？这是否意味着我们应该避免在这里使用流监督器？不均匀的压缩会导致什么样的行为？当涉及到通过Lagom message broker
浏览 25提问于2019-03-12得票数 3
1回答
查询:将路由器接口作为kafka集群的生产者。问题2. kafka消费者可以在不指定主题的情况下拉取数据吗？我刚刚检查了Kafka broker配置是否有"auto.create.topics.e
浏览 1提问于2014-06-18得票数 0
我在我的本地系统上运行apache kafka，它运行得非常好。但是在冒烟测试期间，我的应用程序无法连接到kafka集群。它不断抛出以下错误：[2016-11-22T23:04:35,951][WARN ][org.apache.<e
浏览 0提问于2017-09-08得票数 1
1回答
在春季云流卡夫卡绑定中，是否有一种方法来设置两个重连接尝试之间的重新连接频率或时间？spring.cloud.stream.kafka.streams.binder.configuration.reconnect.backoff.ma
浏览 3提问于2022-04-01得票数 0
回答已采纳
我有一些kafka消费者和生产者(Spring )，当他们连接的Kafka节点出现故障(例如，一个失败)时，他们会记录如下：
2019年-03-15 11:02:53.278警告1--保持器#1-23-C-1 org.apache.kafka.clients.NetworkClient :使用者客户端=消费者-29，连接到节点org.apache.kafka.clients.NetworkClient的groupI
浏览 0提问于2019-03-15得票数 5
我有一个关于从docker连接到kafka broker的问题。但是我既不能用kafka-console-consumer.sh也不能用kafka-cons
浏览 10提问于2019-10-18得票数 2
此外，当处理消息时出现错误时，消费者线程将不会恢复。我们的消费者读取消息并将其插入到MySql中。一旦网络出现故障，消费者就无法连接到MySql，然后它就会阻塞并停止读取消息，直到我们重新启动它。也就是说，如果数据是按散列(键)% number_of_partitions分区的，则此分区可能会通过添加分区来混洗，但Kafka不会尝试以任何方式自动重新分配数据。”“不尝试自动
浏览 57提问于2016-03-20得票数 4
我有一个用例，我想先建立一个Kafka集群，一开始我有一个Kafka代理(A)和一个动物园管理员节点。因此，以下是我的质询：
不让我们想当然地假设这件事！我的数据分布在两个经纪人身上。现在，由于一些维护问题，我想要删除服务器B。如何在不重新启动Kafka的情况下，在运行时更改Kafka
浏览 0提问于2018-12-07得票数 0
我正在尝试将一些非关键数据推送到Kafka中，但我仍然希望应用程序在没有Kafka的情况下运行。Broker may not be available.
基本上，这会阻止对我的应用程序的所有http请求，因为我猜只有当它连接到Kafka时，启动过程才能完成。我想简单地将Kafka视为一个可选服务，即使在生产中我们会不断地启动它，对于任何测试或开发服务器或开发人员机器等，这可能不是真的。基本上“如果它正在运行，将这些数据推送到这个主题，
浏览 16提问于2021-12-02得票数 0
Kafka版本为1.1.0。我设置了以下属性，因为如果出现错误，消息将不会被使用。Kafka使用者为它处理的每个消息调用一个web服务，如果web服务不可用，那么我预计使用者将尝试处理该消息3次，然后再继续处理下一条消息。过了一段时间后，我停止并重新启动了Kafka消费者(webservice仍然是禁用的)。我期望在Kafka消费者重启后，它会尝试处理第一次没有成功处理的消息。在Kafka Cons
浏览 29提问于2019-03-18得票数 2
我正在开发一个Spring Cloud Stream Kafka应用程序。我只添加了消费者来使用来自主题的消息，并使用FIX协议将它们传递给第三方。当我在现有代码中添加一个供应商时，它开始出现奇怪的行为。如果尝试连接localhost会出现错误，因为没有任何Kafka设置。value.serializer: io.confluent.kafka.serializers.KafkaAvroSerializer
spring</
浏览 7提问于2020-07-30得票数 0
回答已采纳
1回答
我搜索过这样的Node包：和
我的问题是:这些包让node.js一直订阅卡夫卡吗？或者，我需要一些包，像永远或pm2来实现这一点？
浏览 4提问于2017-02-03得票数 0
回答已采纳
2回答
我使用spring CachingConnectionFactory来检索连接。在这个连接上，我创建了一个新的会话。我有一个线程与一个消费者创建了该会话。MessageConsumer messageConsumer = new session.createConsumer(destination); // This is passed to new thread
我正在做一些故障转移测试当我从网络连接上拔出服务器时，它失败了。当我再次连接服务器时，我仍然收到相同的异
浏览 0提问于2018-04-24得票数 0
，并将其写回Solace队列(在该队列中，我们没有手动提交，自动提交偏移量为false & isolation.level设置为read_commited)。现在，在启用了第二个服务的事务和隔离级别之后，如果我在第二个服务中禁用了事务，则无法读取任何消息。
- kafka: - transac
浏览 0提问于2019-03-29得票数 1
回答已采纳
2回答
我试图连接我的卡夫卡容器和我的码头形象所有运行在本地，不想创建一个容器与卡夫卡和动物园管理员的形象。 ports: environment: kafka: ports:
- &#
浏览 16提问于2021-12-07得票数 3
1回答
我使用spring-amqp连接到rabbitmq节点集群( A、B和C)。假设集群中的一个rabbitmq节点关闭(C关闭)。另外，假设有两个消息接收器( Receiver_1和Receiver_2 )正在使用到节点C的连接。当C出现故障时，Receiver_1和Receiver_2是否会自动切换它们的连接以连接到A或B？当C再次出现时会发生什么呢？是否将一些接收器连接重新分配为
浏览 1提问于2012-11-02得票数 2
即使RabbitMQ message broker关闭，也可以使用@RabbitListener加载spring上下文吗？行为应该类似于broker断开连接的情况。应用程序正在等待broker，当它恢复时，listerner会自动重新连接。Spring Boot 1.3.2版本
@Bean
public MessageConverter jsonMe
浏览 0提问于2016-02-25得票数 0
对于多实例MQ中的切换、故障转移和自动重新连接，我几乎没有什么疑问。在此过程中通过了。
如果活动实例发生切换或失败，是否会自动重新连接？但是，如果我重新</e
浏览 3提问于2014-11-15得票数 0
回答已采纳
云服务器
ICP备案
云直播
即时通信 IM
实时音视频
腾讯云开发者
