Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
是否可以在 Confluence KSQL 查询中使用多个左连接?尝试加入超过 1 个表的流,如果没有,那么解决方案是什么?
溪流 describe ammas Field Type ROWTIME BIGINT system ROWKEY VARCHAR STRING system ID INTEGER 对于运行时统计信息和查询详细信息 运行 DESCRIBE
ApacheKafka
confluentplatform
ksqldb
Java Apache Kafka Producer 元数据更新器和重试逻辑
我正在使用 Spring for Apache Kafka 并创建了一个服务 该服务通过 Spring 的 KafkaTemplate 使用 Kafka Producer org apache kafka clients Producer
ApacheKafka
kafkaproducerapi
变更日志/重新分区主题的复制因子应该是多少
我知道可以为 kafka 流配置复制因子这些内部主题 我们的应用程序用于复制因子为 3 的普通应用程序主题 但到目前为止我还没有为变更日志 重新分区主题配置复制因子 而我的假设是如果一个经纪人死亡 或由于某种原因领导者发生变化 kafka
ApacheKafka
apachekafkastreams
Debezium PostgreSQL 连接器未创建主题
当我使用启动 Debezium 连接器用于 PostgreSQL 时 未创建 Kafka 主题 这是我的属性文件中的内容 name testdb connector class io debezium connector postgresq
postgresql
ApacheKafka
debezium
确定 Kafka-Client 与 kafka-broker 的兼容性
在远程 kafka 云集群中 kafka 代理将更新到新版本 5 1 因此应用新的 kafka 协议 现在我应该更新我的 kafka 客户端以便能够连接 现在我在我的 spring boot 应用程序中使用以下 kafka 相关依赖项
Java
ApacheKafka
springKafka
java.lang.IllegalArgumentException:Jetty ALPN/NPN 尚未正确配置
Getting java lang IllegalArgumentException Jetty ALPN NPN has not been properly configured 同时使用gRPC google pub sub 发布 消费
Java
springboot
ApacheKafka
classLoader
gRPC
如果第一个经纪人宕机,Kafka 消费者将无法消费
我正在使用最新版本的kafka kafka 2 12 1 0 0 tgz 我已经设置了带有 3 个代理的简单集群 只是在每个实例的属性文件中更改了broker id 1 和listeners PLAINTEXT 9092 集群启动后 我使用
ApacheKafka
failover
consumer
是否可以反序列化 Avro 消息(使用来自 Kafka 的消息)而不在 ConfluenceRegistryAvroDeserializationSchema 中提供 Reader 模式
我在 Apache Flink 中使用 Kafka Connector 来访问由汇流卡夫卡 除了 schema 注册表 url 之外ConfluentRegistryAvroDeserializationSchema forGeneric
ApacheKafka
apacheflink
confluentschemaregistry
如何将 Spark Streaming DF 写入 Kafka 主题
我正在使用 Spark Streaming 处理两个 Kafka 队列之间的数据 但我似乎找不到从 Spark 写入 Kafka 的好方法 我已经尝试过这个 input foreachRDD rdd gt rdd foreachPartit
scala
apachespark
ApacheKafka
SparkStreaming
sparkstreamingkafka
如何有效地将我的@KafkaListener绑定到ConcurrentKafkaListenerContainerFactory?
我遇到了这个对我来说似乎很奇怪的场景 所以基本上我定义了两个 KafkaListener在一堂课中 KafkaListener id listener1 idIsGroup false topics data1 containerFacto
springboot
ApacheKafka
springKafka
具有多个任务的分布式官方 Mongodb Kafka 源连接器无法正常工作
我正在我的 Windows 机器上运行 Apache Kafka 有两个 Kafka Connect Workers 端口 8083 8084 和一个具有三个分区的主题 一个复制 我的问题是 每当我关闭其中一个 Kafka Connect
使用 2 个消费者配置时消费者吞吐量缓慢
使用 spring integration kafka 扩展和以下配置
Spring
springintegration
apachezookeeper
ApacheKafka
Kafka 0.11.0.0 在重启时不断重置偏移量
我的 Kafka 0 11 0 0 有问题 当我创建新主题时 将数据放入其中并使用 java 消费者使用它 重新启动 Kafka 0 11 0 0 后 我的消费者组的偏移量消失 主题保持不变 其中包含相同的数据 只有偏移量被清除 这使得消费
Java
ApacheKafka
Kafka 流过滤:代理端还是消费者端?
我正在研究卡夫卡流 我想使用选择性非常低 几千分之一 的过滤器来过滤我的流 我正在看这个方法 https kafka apache org 0100 javadoc org apache kafka streams kstream KStr
ApacheKafka
kafkaconsumerapi
apachekafkastreams
测试框架意外退出 - 空手道测试
我将一个空手道项目导入到我的 Intellij 中 我已经把maven清理干净了 当我运行它时 我收到消息 测试框架意外退出并出现以下错误 Testing started at 10 24 C Users oluseyiojo Downlo
javascript
Java
ApacheKafka
karate
如何将两个不同Spout的输出发送到同一个Bolt?
我有两个 Kafka Spout 我想将它们的值发送到同一个 Bolt 是否可以 对的 这是可能的 TopologyBuilder b new TopologyBuilder b setSpout topic 1 new KafkaSpou
Java
ApacheKafka
apachestorm
使用 Kafka 主题后发送 HTTP 响应
我目前正在编写一个包含大量微服务的 Web 应用程序 我目前正在探索如何在所有这些服务之间正确通信 并且我决定坚持使用消息总线 或更具体地说是 Apache Kafka 然而 我有一些问题 我不确定如何从概念上解决 我使用 API 网关服务
javascript
nodejs
ApacheKafka
microservices
backend
Apache Kafka 和 JMS 之间的连接
我想知道 Apache Kafka 可以通信并将消息发送到 JMS 吗 我可以在它们之间建立连接吗 例如 我在我的系统中使用 JMS 它应该将消息发送到使用 Kafka 的其他系统 回答有点晚了 但如果我正确理解了要求 如果要求是同步消息传
JMS
ApacheKafka
重新启动集群时连接消费者作业被删除
我在更改与 kafka 相关的一些属性并重新启动集群时面临以下问题 In kafka Consumer there were 5 consumer jobs are running 如果我们进行一些重要的属性更改 并且在重新启动集群时 某些
ApacheKafka
apachekafkaconnect
Apache Kafka:...StringDeserializer 不是 ...Deserializer 的实例
在我的简单应用程序中 我尝试实例化 KafkaConsumer 我的代码几乎是来自 javadoc 的代码 自动偏移量提交 Slf4j public class MyKafkaConsumer public MyKafkaConsumer
ApacheKafka
kafkaconsumerapi
«
1 ...
27
28
29
30
31
32
33
...35
»