1回答
我在Kafka中得到了错误。同时发送关于主题的消息 以下是发送topic消息的代码。channelConfiguration.getTopic(), e); }
} 这是我在主题上发送消息时遇到的错误Caused by: java.util.concurrent.ExecutionException: org.springframework.kafka.core.
浏览 111提问于2020-09-14得票数 0
1回答
我已经在集群中配置了3个kafka，我正在尝试使用spring。代码：public KafkaSyncListener synchronousListener(MessageSender sender,;}
org.
浏览 2提问于2018-06-11得票数 6
，value = 99,105,110,102,111，45,114,101,112,108,121)，RecordHeader(key = kafka_correlationId )，”
通常，当出现超时异常时：() for servlet dispatcherServlet在路径[]中抛出的异常请求处理失败；嵌套异常是java.util.concurrent.ExecutionException: java.util.concurrent.ExecutionException失败<e
浏览 2提问于2020-07-02得票数 0
:未明翻译错误: java.util.concurrent.ExecutionException: java.lang.OutOfMemoryError: GC开销超出错误:未明翻译错误: java.util.concurrent.ExecutionException: java.util.concurrent.ExecutionException: java.lang.OutOfMemoryError: GC开销限制超出错误:未明翻译错误: java.util.concurrent.Execut
浏览 2提问于2016-08-04得票数 4
回答已采纳
我写了一个Java程序，它使用了Kafka库，我听说Kafka生产者有内部缓冲区来保存消息，这样它可以在以后重试。所以我创建了具有重试属性的幂等Kafka生成器。props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, System.getenv(KafkaConstants.KAFKA_URL));
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.
浏览 3提问于2018-01-22得票数 0
回答已采纳
根据KIP-368 ()，当“connections.max.reauth.ms”显式设置为正数时，服务器将断开任何不重新验证的SASL连接。如果重新身份验证尝试失败，则代理将关闭连接，不支持重试。然而，当我的客户端无法重新验证时，它会进入无限的重试循环。INFO [kafka-producer-network-thread | producer-1] org.apache.kafka.common.network.Selector: [Producer| producer-1] org.apache.<
浏览 3提问于2020-03-05得票数 1
1回答
对于运行在AWS EC2实例上的kafka集群，我经常遇到问题。
java.util.concurrent.ExecutionException:
浏览 1提问于2017-07-24得票数 0
回答已采纳
我刚刚安装了Cloudera QuickStart VM，并在其中添加了Kafka服务。在添加了Kafka服务之后，我可以轻松地创建一个生产者/消费者，一切都如预期的那样工作。几天后，虚拟机重新启动，我得到了以下异常：
线程“主”org.apache.kafka.common.errors.TimeoutException:中的异常: 60000 ms后，java.util.concurrent.ExecutionExceptionat test.kafka.KafkaProducerExam
浏览 0提问于2018-04-06得票数 0
我们正面临着一个特殊的问题，当我们向Kafka发出消息时，有时消费者端找不到它。我们尝试进一步调试，并启用了onSuccess()和onFailure()回调。我们得到的主要问题是- org.springframework.kafka.core.KafkaProducerException: Failed to send; nested exception isorg.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not
浏览 114提问于2020-07-11得票数 1
回答已采纳
1回答
我正在尝试读取100k文件并将其发送到kafka主题。这是我的Kafka代码，它将数据发送到Kafka-console-consumer。当我发送数据时，我接收的数据是这样的下面是我发送的单条记录数据示例：
173|172686|54824707920161231:22143|548247079||0|173||172686|5:2266490827:DC
浏览 21提问于2016-09-22得票数 2
卡夫卡生产者的Spring引导属性：spring.kafka.client-id=bamspring.kafka.producer.bootstrap-servers=localhost:9092spring.kafka</e
浏览 3提问于2017-07-03得票数 1
回答已采纳
我已经在我的Windows10笔记本电脑上在WindowsLinux3.4.12下安装了Kafka1.1.0和ZooKeep3.4.12。我可以在ubuntu中获取和使用消息，但是当我想从windows (使用java程序或使用kafka-console-Producer.bat工具)生成消息时，我有以下错误：
2018-05-11 15:31:01,449在用键向主题测试发送消息时出错: null，值: 15字节带有错误：(org.apache.kafka</
浏览 0提问于2018-05-11得票数 0
为什么kafka 0.10控制台生产者不能向kafka 0.9发送消息？
我在0.9版本中启动了kafka控制台消费者(在服务器端)。我正在启动0.10版本的kafka控制台生产者(在客户端)。为什么新的生产者不能向旧的消费者发送消息？是否可以将新的生产者设置为一种弃用模式，以便向旧的kafka发送消息？53,365错误kafka生产者I/O线程未捕获错误:读取字段‘brokers’时出错
浏览 11提问于2016-08-30得票数 0
回答已采纳
在我们的项目中，我们需要通过许多线程定期从第三方获取数据，然后将这些数据推送给Kafka。如果目前无法使用Kafka服务器，则应该终止流，在下一次预定执行过程中应该丢失并重新获取获取的数据。此外，还需要使用事务管理，因为我们需要将这批消息发送给Kafka到不同的主题。如果没有发送一条消息，则所有其他消息都应该回滚。
如果Kafka Server不可用，我们就遇到了终止执行的问题。但是在启用事务管理的情况下，Kafka
浏览 1提问于2018-07-16得票数 2
我在ApacheKafkav2.0.1中使用了spring&spring(具体版本见pom.xml )，并且在通过侦听器容器使用事务时遇到了一个奇怪的问题。正如您在output.log上可能看到的那样，当第一次尝试(message )处理失败时，侦听器容器启动事务回滚，然后再次接收相同的消息(如预期的那样)。: org.springframework.kafka.core.KafkaProducerException: Failed to send; nested exception is org.apache.<
浏览 0提问于2019-04-04得票数 0
获取以下eeror- org.springframework.kafka.KafkaException:发送失败；嵌套异常是60000 ms后元数据中不存在的org.springframework.kafka.KafkaException
浏览 5提问于2022-10-03得票数 0
回答已采纳
我正在通过Kafka模板向Kafka发送消息，但我想测试异常，所以我提供了错误的主题名称，但当我运行代码时，它说“获取相关id为2的元数据时出错：{ocf-oots-gr-outbound_123=LEADER_NOT_AVAILABLE”不可用，但主题本身是在Kafka中创建的，我也可以通过Kafka工具看到，当broker停止时，它也没有抛出异常。//kafkaTemplate.send(Co
浏览 19提问于2019-07-22得票数 0
回答已采纳
在spring boot项目中使用kafka模板发送消息 import org.apache.kafka.clients.producer.ProducerConfig;import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.kafka.core.Produc
浏览 242提问于2019-01-04得票数 1
回答已采纳
1回答
我正在尝试读取xml文件并将其发送到kafka主题。这是我的卡夫卡代码，它把数据发送给卡夫卡-控制台-消费者。java.io.FileReader;import java.util.Properties;import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutionException
浏览 0提问于2016-09-19得票数 2
在尝试使用以下命令启动kafka connect时，获取下面的错误：
在plugin.path=C:\Kafka\kafka_2.12-2.7.0\plugins\debezium-connector-sqlserver\config\connector.properties (org.apache.kafka
浏览 22提问于2021-02-18得票数 0
云服务器
ICP备案
云直播
腾讯会议
实时音视频
腾讯云开发者
