腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Kafka
Producer
窗口
不允许
我
添加
消息
powershell
、
apache-kafka
我
在Powershell中运行
Kafka
。
我
正在按照一个教程,并试图让
我
的生产者再次运行(
我
必须重新启动
我
的计算机)。
我
运行了以下命令: bin/windows/
kafka
-console-
producer
.bat --broker-list localhost:9092 --topic my-replicated-topic但在那之后,
我
不能输入
我
的
消息
,即使
浏览 12
提问于2020-07-15
得票数 0
1
回答
在发送avro
消息
时获取异常,异常是注册Avro模式的org.apache.
kafka
.common.errors.SerializationException:错误:
java
、
spring-boot
、
avro
、
spring-cloud-stream
、
confluent-schema-registry
我
正在使用spring云流并试图发布avro
消息
,但是得到了上述异常,spring.cloud.stream.bindings.feed-output-channel.
producer
.useNativeEncoding=headers['
kafka
_messageKey'] spring.cloud.stream.
kafka
.bindings.feed-output-channel.
producer
.configuration.
浏览 14
提问于2022-01-21
得票数 0
回答已采纳
1
回答
如何在Windows上生成即席
Kafka
消息
?
windows
、
apache-kafka
有没有一种简单的方法来产生一些特别的
Kafka
消息
,而不需要设置任何编程环境?
浏览 0
提问于2017-11-26
得票数 0
2
回答
消息
不使用
kafka
python传递
python
、
apache-kafka
、
kafka-python
我
正在尝试用设置一个简单的
Kafka
应用程序。
我
一直在尝试让
我
在网上找到的一些例子起作用,但似乎无法做到。
我
有一个运行在docker容器中的
kafka
实例。
我
测试了shell工具,实例确实工作正常。
我
能够发送和接收
消息
。
我
怀疑生产者
消息
超时了。下面是代码的两个版本,它们的行为基本相同:from
kafka
import SimpleProducer, Ka
浏览 21
提问于2017-07-09
得票数 3
1
回答
如何使用JSON模式通过
Kafka
控制台消费和生成
消息
json
、
apache-kafka
、
kafka-consumer-api
、
kafka-producer-api
、
confluent-schema-registry
是否可以分别使用
kafka
-console-consumer和
kafka
-console-
producer
在
Kafka
中使用和生成JSON模式的
消息
?
浏览 2
提问于2020-04-29
得票数 2
回答已采纳
5
回答
如何使用
kafka
-控制台-生成器生成
消息
到选定的分区?
apache-kafka
根据卡夫卡的文件:
我
想在
消息
发送时指定某种“分区id”。
浏览 5
提问于2014-10-24
得票数 21
回答已采纳
4
回答
Kafka
Connect -刷新失败,等待生产者刷新未完成
消息
时超时
apache-kafka
、
apache-kafka-connect
、
kafka-producer-api
我
尝试在批量模式下使用具有以下属性的
Kafka
Connect JDBC源连接器。io.confluent.connect.jdbc.JdbcSourceConnectorconnection.password=XXXXXtasks.max=1batch.size=1000off
浏览 4
提问于2019-04-05
得票数 16
3
回答
Kafka
生产者JSON序列化
spring
、
apache-kafka
、
spring-cloud-stream
、
spring-kafka
我
正在尝试使用Spring Cloud Stream来集成
Kafka
。正在编写的
消息
是Java POJO,虽然它的工作方式与预期一样(
消息
正在写入主题,
我
可以使用消费者应用程序读取),但
消息
的开头
添加
了一些未知字符,这在尝试集成
Kafka
Connect以接收主题中的
消息
时会造成麻烦在默认设置下,这是推送到
Kafka
的
消息
: contentType "text/pl
浏览 1
提问于2017-11-21
得票数 3
回答已采纳
1
回答
丢失来自
Kafka
主题的
消息
java
、
apache-kafka
、
kafka-producer-api
在中尝试使用时间戳时,
我
发现了一些奇怪的东西。在从生产者发送了几条
消息
之后,
我
运行了
kafka
-console-consumer.sh并验证了这些
消息
是否在主题中。
我
叫住制片人,等了一分钟。当我重新运行
kafka
-console-consumer.sh时,它没有显示
我
之前生成的
消息
。
我
还
添加
了
producer
.flush()和
producer
.close(),但结
浏览 19
提问于2019-11-23
得票数 1
2
回答
Kafka
: java客户端在x次尝试后未能发送
消息
java
、
apache-kafka
我
试图从Java应用程序向
Kafka
发送
消息
。
我
所能得到的只有“两次尝试后未能发送
消息
”: at
k
浏览 3
提问于2015-06-16
得票数 3
回答已采纳
1
回答
spring集成
kafka
xml异常
spring-integration
我
使用的是Spring Integration
Kafka
1.3.0版本,但我仍然得到如下异常。那么有没有解决这个问题的办法呢?
kafka
-
producer
-context-ref="kafkaProducerContext"
producer
浏览 1
提问于2015-12-19
得票数 1
3
回答
Kafka
2.9.2-0.8.1.1无KeyedMessage参数用于
producer
.send
java
、
apache-kafka
我
正在用java向
Kafka
发送一个信息。
我
的项目通过maven依赖项使用
kafka
_2.9.2-0.8.1.1.jar: <groupId>org.apache.
kafka
</groupId> <artifactId>log4j</artifactId> </exclusio
浏览 6
提问于2015-01-06
得票数 2
回答已采纳
2
回答
无法向
Kafka
Python中的Topic发送
消息
python
、
apache-kafka
、
kafka-python
我
有一个生产者代码,在那里
我
发送
消息
给卡夫卡。没有任何失败或错误
消息
,代码可以执行,但不会发送
消息
。
kafka
-python==2.0.1下面是
我
的代码,import loggingINFO:
kafka
.con
浏览 3
提问于2020-06-16
得票数 0
2
回答
可能使用
Kafka
-连接器从Python-Opcua客户端获取数据到
Kafka
主题
apache-kafka
、
opc-ua
self, node, val, data)将作为python opcua client的一部分执行,每当client到达新数据时,请参见下面的脚本,是否可以将到达的数据(在这个上下文中是val)发送到
kafka
-client
浏览 1
提问于2020-02-19
得票数 0
回答已采纳
2
回答
kafka
在线
添加
分区或broker安全吗?
apache-kafka
、
kafka-consumer-api
、
kafka-producer-api
在线为主题
添加
分区后,
kafka
消费者停止读取
消息
,不会抛出异常。消费者只是阻塞。每次我们都必须重启消费者。
我
认为这是不合理的,
我
找不到任何关于它的文档。此外,当处理
消息
时出现错误时,消费者线程将不会恢复。我们的消费者读取
消息
并将其插入到MySql中。一旦网络出现故障,消费者就无法连接到MySql,然后它就会阻塞并停止读取
消息
,直到我们重新启动它。也就是说,如果数据是按散列(键)% number_of_partitions分区的,则此分区可能会通过<e
浏览 57
提问于2016-03-20
得票数 4
2
回答
键控的
kafka
消息
似乎总是指向同一个分区。
apache-kafka
、
kafka-consumer-api
、
kafka-producer-api
我
的节点应用程序使用
kafka
节点模块。
我
有一个
kafka
主题,有三个分区,如下所示:当我将一系列键控
消息
写入
我
的主题时
我
希望
我
浏览 2
提问于2020-03-19
得票数 1
回答已采纳
2
回答
卡夫卡简单的制作人不发送信息,也不出错
python
、
json
、
serialization
、
apache-kafka
、
confluent-platform
我
正在写一个简单的生产者,
我
只是想发送原始数据到一个主题。由于某些原因,
我
需要指定序列化器,它将
消息
转换为json,然后再转换为utf-8,然后发送一条json
消息
。这段代码不起作用(没有错误,但在主题中没有什么可使用的)topic = "my_ne
浏览 0
提问于2019-06-28
得票数 1
回答已采纳
1
回答
在
kafka
生产者中使用/127.0.0.1 (SSL握手失败) (org.apache.
kafka
.common.network.Selector)获得失败的身份验证
ssl
、
apache-kafka
、
ssl-certificate
我
使用以下命令在
kafka
中配置SSL:openssl req -new -x509 -keyout ca-key -out ca-cert -days 3650keytoolca-signed-
kafka
ssl.truststore.location=PATH-TO-YOUR-
KAFKA
-DIR/ssl/
kafka
.broker0/config/
p
浏览 2
提问于2021-12-08
得票数 1
1
回答
同步卡夫卡制作人发送还有0秒超时吗?
python
、
apache-kafka
我
在Python脚本中有以下代码
kafka
_
producer
.flush() 然而,
我
仍然看到了
浏览 6
提问于2020-11-06
得票数 1
3
回答
如何将创建的用户传给Kubernetes Strimzi
Kafka
Operator集群中的
producer
.sh/consumer.sh?
apache-kafka
、
kafka-consumer-api
、
kafka-producer-api
、
strimzi
我
为
Kafka
和启用的TLS/ACL部署了Strimzi运算符,现在
我
卡住了!如何在用户创建的9093上运行
producer
.sh/consumer.sh?以下是使用端口9092上禁用的ACL的命令: kubectl -n myproject run
kafka
-
producer
-ti --image=strimzi/
kafka
:0.14.0-
kafka
-2.3.0 --rm=true --restart=Never -
浏览 65
提问于2020-04-15
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Kafka使用及Python示例
Python操作分布式流处理系统Kafka
“事件驱动架构”Kafka中的模式注册表和模式演化
kafka之producer
如何为Kafka集群选择合适的Topics/Partitions数量
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券