我写了一个Java程序，它使用了Kafka库，我听说Kafka生产者有内部缓冲区来保存消息，这样它可以在以后重试。所以我创建了具有重试属性的幂等Kafka生成器。props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, System.getenv(KafkaConstants.KAFKA_URL));
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, "org.apache.ka
浏览 3提问于2018-01-22得票数 0
回答已采纳
假设有以下场景：
我在本地启动zookeeper和一个kafka代理，并创建“测试”主题，如kafka快速入门：中所述。然后，我运行一个简单的java程序，该程序每秒生成一条指向"test“主题的消息。一段时间后，我关闭了我的本地kafka代理，看到producer继续生成消息，它没有抛出任何异常。最后，我再次启动kafka broker，producer能够重新连接到broker，并继续生成消息，但是，在kafka
浏览 1提问于2018-04-06得票数 1
在我们的项目中，我们需要通过许多线程定期从第三方获取数据，然后将这些数据推送给Kafka。如果目前无法使用Kafka服务器，则应该终止流，在下一次预定执行过程中应该丢失并重新获取获取的数据。此外，还需要使用事务管理，因为我们需要将这批消息发送给Kafka到不同的主题。如果没有发送一条消息，则所有其他消息都应该回滚。
如果Kafka Server不可用，我们就遇到了终止执行的问题。但是在启用事务管理的情况下，K
浏览 1提问于2018-07-16得票数 2
我在Kafka中配置了3个代理，运行在不同的端口上，.I正在使用spring cloud stream kafka
brokers: localhost:9092,localhost:9093,localhost我正在创建一个数据管道，以获得连续的数据流.I正在与运行.Till的3个代理在kafka主题中存储数据流现在没有问题.My问题假设假设3个代理停机了5分钟，那么到那时我无法获取有关kafka的数据主题.There将丢失数据5分钟.From spring启动我<
浏览 0提问于2020-10-06得票数 1
3回答
正在编写的消息是Java POJO，虽然它的工作方式与预期一样(消息正在写入主题，我可以使用消费者应用程序读取)，但消息的开头添加了一些未知字符，这在尝试集成Kafka Connect以接收主题中的消息时会造成麻烦在默认设置下，这是推送到Kafka的消息：
contentType "text/plain"originalContentType "application/json;charset生产者，
浏览 1提问于2017-11-21得票数 3
回答已采纳
我想知道spring boot内部的spring kafka Producer是否保证交付。
有人知道如果某个随机监听器无法接收消息会发生什么情况吗？spring kafka是否会重试发送消息？
浏览 0提问于2019-05-29得票数 0
刚刚安装了spotify/kafka的Docker镜像。sudo docker ps：
82c411a52a38 spotify/kafka "supervisord -n" 26 minuteskafka-console-producer.sh来测试安装，就像https://hub.docker.com/r/spotify/kafka/一
浏览 4提问于2016-05-03得票数 1
我打算使用Spring boot和webSocket以及Kafka实现一个聊天室，但是我需要知道Kafka是否提供了异步消息传递服务
浏览 2提问于2019-07-02得票数 0
我试图从Java应用程序向Kafka发送消息。我所能得到的只有“两次尝试后未能发送消息”：Kafka运行在远程机器上，所以我将其添加到server.properties中(假设Kafka服务器的IP地址为192.168.0.1)：
host.name=192.16
浏览 3提问于2015-06-16得票数 3
回答已采纳
1回答
可以配置kafka消费者，并在调试时确认其在每次轮询kafka主题时消耗数千条消息。
另一方面，Azure服务总线将始终发布一条消息。因此，当集成运行时，kafka日志将显示接收到数千条消息，然后Azure服务总线日志将迭代每个消息，每次发送一个消息到队列。这需要几分钟的迭代，大大减缓了进程的速度。Server -> Lo
浏览 11提问于2022-06-26得票数 0
在Cloud中，我能够向非ssl url ("kafkaURL:9092")生成消息。但是它不适用于ssl url ("kafkaURL:9093")。Kafka服务器版本0.10.0.1和客户端版本0.10.0.0。", producerType)当从Kafka服务器上的ka
浏览 2提问于2017-01-24得票数 0
回答已采纳
现在，当应用程序启动时，我们可以看到如下日志当向主题生成第一条消息时，我们可以
浏览 147提问于2021-03-12得票数 1
回答已采纳
1回答
如何处理卡夫卡中的大消息，比如超过20 to的消息等等。2009-03- 13 08:59:10,923错误当发送消息到主题测试时，键:13字节，值: 11947696字节与错误：(org.apache.kafka.clients.producer.internals.ErrorLoggingCallback) org.apache.kafka.common.errors.RecordTooLargeException:请求包含一条大于服务器<
浏览 0提问于2019-03-13得票数 1
回答已采纳
flume-kafka-sink遇到了奇怪的问题，kafka代理多次失败并产生重复消息(每50条记录相同)，但是关于producer.sinks.r.request.required.acks = 1的设置，对kafka文档的配额“此选项提供了最低的延迟，但最薄弱的持久性保证(一些数据将在服务器故障时丢失)”，它不能生成重复的数据吗？这意味着flume或flume-kafka-sink引起的问题吗？
浏览 5提问于2017-11-03得票数 0
回答已采纳
我正在使用kafka控制台工具，并试图设置它，如果至少有一个kafka服务器实例仍然在线，仍然可以发送和接收消息，同时使用复制。配置:动物园管理员(本地宿主:2181)，kafka1 (本地宿主:9092)，kafka2 (本地宿主:9093)，producer1 (本地宿主:9092)，producer2(本地宿主:9093)在我看来，消息需要复制到kafka1才能交付。1)为什么两个消费者都
浏览 6提问于2017-02-28得票数 0
回答已采纳
Kafka客户端: 0.11.0.0-cp1 Kafka Broker：val acksConfig: String = "
浏览 0提问于2019-03-20得票数 0
1回答
我试图在java 1.6上运行kafka producer，我使用的是0.8.1.1版本。它正在运行，但是当它试图发送消息时，它给出了
Exception in thread "Main" kafka.common.FailedToSendMessageException: Failed toat kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.
浏览 5提问于2016-02-07得票数 0
回答已采纳
:outbound-channel-adapter id="kafkaOutboundChannelAdapter" producer-properties="producerProperties">
<int-kafk
浏览 1提问于2015-12-19得票数 1
云服务器
ICP备案
实时音视频
即时通信 IM
云直播
腾讯云开发者
