apache-kafka

英文: KafkaStream Vs Flink 问题 我已经使用Flink将数据从源发送到目标。 我的Flink应用程序从Kafka消费数据并发送到目标。 目标也是Kafka主题，具有不同的主题名称...

英文: Kafka issue: MessageConversionException: Cannot convert from [java.lang.String] to [my_custom_mo...

英文: Goroutine Kafka Consumers 问题 我目前有一个程序，它创建了一个大小为1的工作组，然后调用startworker函数： package main import ( &#...

英文: Broker not available when publishing to Redpanda broker 问题 当我尝试向Redpanda代理发布消息时，我遇到了错误The broker...

英文: segmentio/kafka-go reader client not subscribing to the topic and partition 问题 读取客户端没有开始消费消息。这种情...

英文: Parse Kafka.header to int in go lang 问题 我一直在尝试将 []kafka.Header 转换为 Go 中的 int。到目前为止，我已经尝试了几种方法。 其...

英文: Overwriting an existing golang structure and adding a field 问题 func (c *client) Init(conf config...

英文: Use variable out of conditional block in golang 问题 func CheckKafkaReadPartitions(kafkabroker str...

英文: Unable to Update partitions in kafka using Sarama Library 问题 我已经尝试使用Sarama Go库来更新Kafka中的分区，有人可以建...

英文: How to change offset of a topic during runtime? 问题 我有一个为 Kafka 主题提供消息的生产者，并且还有另一个服务从主题中读取这些消息。 我...