英文: How to consume the last 5 minutes data in Kafka using confluent kakfa python package? 问题 我目前能够消费...
144评论apache-kafka
python
如何使用Confluent Kafka Python包消费Kafka中的最后5分钟数据？
144评论apache-kafka
python
144评论apache-kafka
python
Java请求中多个对象之间共享的常见变量
英文: Java common variable across the objects for a request 问题 I using Kafka to get a message and upda...
135评论apache-kafka
java
Kafka lag with read_uncommitted isolation level.
英文: Kafka lag with read_uncommitted isolation level 问题 未提交的记录在 Kafka 滞后中计算吗，如果消费者配置为仅读取已提交的记录？ 我阅读了文...
99评论apache-kafka
RetryTopicConfigurationSupport produces exception: Either a RetryTopicSchedulerWrapper or TaskScheduler bean is required
英文: RetryTopicConfigurationSupport produces exception: Either a RetryTopicSchedulerWrapper or TaskSc...
161评论spring
spring-boot
修改 MSK 连接器中的 client.dns.lookup
英文: Alter client.dns.lookup in MSK connector 问题 我有一个AWS MSK托管连接器，似乎使用了这个默认配置 - client.dns.lookup = u...
122评论apache-kafka
apache-kafka-connect
连接 Kafka 流与全局 K 表，使用非键值方式。
英文: Kafka- Joining a Kafka Stream with a Global K Table using non key value 问题 I've seen multiple po...
121评论apache-kafka
apache-kafka-streams
Apache Kafka 版本 2.1.1 和 log4j 最新版本 2.17
英文: Apache Kafka v. 2.1.1 and log4j latest v 2.17 问题 我们在将log4j从1.2.17升级到2.17以避免Log4j引起的漏洞时，在Zookeepe...
111评论apache-kafka
log4j2
How to handle unconsumed message in kafka without using the DLQ
英文: How to handle unconsumed message in kafka without using the DLQ 问题 我正在使用Kafka发送消息到特定主题，并使用特定的消费者...
119评论apache-kafka
java
Kafka General A client SSLEngine created with the provided settings can't connect to a server SSLEngine created with those settings
英文: Kafka General A client SSLEngine created with the provided settings can't connect to a serve...
129评论apache-kafka
docker
Could not determine output schema for query due to error: Can't find any functions with the name 'OUNT_DISTINCT'
英文: Could not determine output schema for query due to error: Can't find any functions with the ...
107评论apache-kafka
ksqldb
41