Apache Beam管道写入多个水槽
我有一个需要进行以下操作的方案： 从GCS中存储的文件中读取数据， 将多个转换应用于数据。 坚持Google大查询中的PCollection。 步骤3。成功时，将PCo…
S3接收器连接器配置基于Debezium消息的操作类型
我们希望根据操作类型区分Kafka（来自Debezium）中的消息。 我们正在寻找基于Kafka操作类型的路由消息。 Debezium发送不同类型的操作类型，例如R（rea…
在火花结构化流应用程序中计算Kafka滞后
我正在尝试计算我的火花结构流应用程序上的kafka滞后。 我可以从随附的实际数据中获得当前处理的偏移量。 有没有办法通过SPARK界面以编程方式在Kafka…
保证处理 - 如何在两个基于消息的服务之间实施？
我正在开发一个由2个服务组成的应用程序。这些服务是基于消息的，并通过Apache Kafka进行通信（服务1-＆GT;服务2，服务2 - ＆GT;服务1的另一个主题1）…
TypeError：＆＃x27; str＆＃x27;对象不可呼出-JSON -Python
我需要一些帮助。 我使用df.to_json将数据框转换为JSON 我现在正在尝试将此JSON消息发送给Kafka，但是我遇到了错误： TypeError: 'str' object is not…
HPA无法从Kafka出口商获得自定义度量标准
我正在尝试将Prometheus，Custom Metric和Kafka导出用于我的Helloworld HPA。不幸的是，我在HPA事件上遇到了这些错误无法获得Metric Kafka_consumergr…
如何实现kStream-ktable左键，如何通过使用信封对象获得和设置字段并为kStream-ktable实现加入？
如果我有一个主题架构（即KStream）： { "type": "record", "name": "Value", "namespace": "test1", "fields": [ { "name": "id", "type": { "type":…
无法通过Confluent模式注册表的用户身份验证在Clickhouse Kafka引擎上
我想使用ClickHouse Kafka引擎消费使用Avroconfluent格式的消息。在ClickHouse文档之后，我将 format_avro_schema_redistry_url 添加到 etc/clickhous…
Nodejs Kafka生产商无法发送消息
我是Kafka的初学者，我正在尝试向Confluent Cloud上的Kafka生产商传达消息。但是，我的生产者实例某种程度上无法创建，或者在那里发生了一些我无法理…
Apache Beam WriteTokafka（Python SDK）dom do to to to to to to topector（没有错误的清单）
我正在尝试使用Writetokafka类Apache Beam（Python SDK）写入Kafka主题的流。但是，它无休止地运行脚本（没有错误），并且不会将流写入主题。我必须取…
Apache Kafka的Oracle Service Bus Transport：在运行install.py时投掷WLSTEXCEPTION
我要在OSB 12C中配置Kafka。 我遵循此博客中显示的确切步骤 https://github.com/oracle/osb-kafka-kafka-transport 但是，在尝试运行 java weblogic.w…
我如何在Terraform中为Kafka配置ZK端口
如你所知。 Kafka取决于Zookeeper。 我想为kafka配置ZK端口。 ZK terraform { required_providers { docker = { source = "kreuzwerker/docker" } } }…
需要使用Kafka的Signalr Trigger的Xunit测试案例
我的Azure函数中有2种方法 signalr to Kafka-使用httptrigger 将数据写入kafka kafka将数据写入Kafka来发出信号 - 该数据使用kafkatrigger 读取来自ka…
kafka |确切的一方面消费者不止一次消耗消息
在我们的应用程序中，在生产者和消费者中都完全启用了。 生产者是python组件。我们已经启用了： iDempotence 使用交易（每次发送消息时每次使用新的Tr…
