英文: Why Karafka Server Throw error query watermark offset? 问题 我正在为我的Ruby on Rails应用程序使用这个宝石来生成和消费来自K...
如何增加Kafka中的代理数量?
英文: How to increase the number of brokers in kafka? 问题 我是新手对于Kafka。我尝试使用3个分区和3个复制因子在Kafka上创建一个主题。我正在...
ConsumerConfig.ALLOW_AUTO_CREATE_TOPICS_CONFIG = false 不起作用。
英文: ConsumerConfig.ALLOW_AUTO_CREATE_TOPICS_CONFIG = false is not working 问题 SpringBoot2 SpringKafka...
模式注册表何时删除自动注册的模式?
英文: When does schema registry remove the schemas which are auto registered 问题 当客户端生产者启用了auto.registe...
从Kafka主题消费XML。
英文: Consume XML from Kafka topic 问题 我需要从Kafka主题中消费XML类型。在阅读了一些资源后,我得出了结论,我可能需要编写自己的"序列化器"。...
为什么外部连接到Kafka不起作用?
英文: Why doesn't work external connection to Kafka? 问题 我在K8s集群中创建了Kafka服务和Kafka Pod,并部署了我的应用程序。因此...
Kafka 主题的每日数据量
英文: Volume/Day on a Kafka Topic 问题 Our Kafka is KDC Integrated in linux environment and RBAC is mana...
如何在处理来自Kafka的记录时将字节转换为字符串?
英文: How to convert bytes to string while processing records from Kafka? 问题 我正在使用Spark与Kafka。我正在运行一个流...
可以使用Flink作业根据通过Kafka传入的数据来分割并发送数据到多个作业吗?
英文: Can I use a flink job to split and send data to multiple jobs according to the incoming data via...
无法在使用PySpark将数据从Kafka主题写入HDFS时实现所需的目录结构。
英文: Can't achieve desired directory structure when writing data from Kafka topic to HDFS using P...
41