我正在使用Kafka producer 10.2.1创建一个主题并将其写入主题,当我创建该主题时,我会得到以下错误,但该主题是创建的:
java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
at org.apache.kafka.clients.producer.KafkaProducer$FutureFailure.<init>(KafkaProducer.java
当我在没有SASL的服务器上运行它时,我的rabbitmq连接器工作正常。实际上,它也是在SASL激活的服务器上工作的,但是在重新启动Kafka服务之后,它就不能开始工作了。错误是:
org.apache.kafka.common.errors.TimeoutException: License topic could not be created
Caused by: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.
这是许可证问题吗?我不认为我们为它购买了任何许
在我的IDE中,我能够利用一个spring-boot应用程序,该应用程序将向外部kafka代理生成消息(使用kafka produce )。但是,一旦我在docker容器中托管了我的spring-boot应用程序,我的应用程序就不能再提交给代理。以下是错误消息:
o.s.k.support.LoggingProducerListener: Exception thrown when sending a message with key='null' and payload='....' to topic Category:
org.apache.kaf
当尝试在kafka上生成消息时,不断获得log:reactor.core.Exceptions$ErrorCallbackNotImplemented: org.apache.kafka.common.errors.TimeoutException: Topic topic not present in metadata after 60000 ms. Caused by: org.apache.kafka.common.errors.TimeoutException: Topic topic not present in metadata after 60000 ms.。 我已经确保我在生
我正在运行Hazelcast-Jet的3节点嵌入式集群,控制台中经常出现以下错误。可能的原因是什么? [jet] [3.0] Execution of job '15ba-4fbe-1b73-9ed1', execution 61d7-46eb-5875-8799 failed after 60,112 ms
com.hazelcast.jet.JetException: Exception in ProcessorTasklet{streamKafka#1}: org.apache.kafka.common.errors.TimeoutException: Tim
我用一个简单的测试创建了一个新的spring boot项目: @RunWith(SpringRunner.class)
@SpringBootTest
public class ExampleApplicationTests {
@Test
public void contextLoads() {
}
} 当我运行这个测试时,它成功了。但是如果我向任何服务添加任何带注释的方法@KafkaListener注释: @KafkaListener(topics = "test", groupId = "v-group")
public vo
我目前正在编写一个Samza脚本,它将从Kafka主题中获取数据,并将数据输出到另一个Kafka主题。我已经编写了一个非常基本的StreamTask,但是在执行时我遇到了一个错误。
错误如下:
Exception in thread "main" org.apache.samza.SamzaException: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 193 ms.
at org.apache.samza.coordinator.stream.Coo