以下是为您整理出来关于apache-kafka合集内容,如果觉得还不错,请帮忙转发推荐。
我正在构建一个Spring Kafka Consumer应用程序,该应用程序使用来自Kafka Topic的消息并执行数据库任务。每天
我对整个微服务体系结构还很陌生,所以我一直在使用Kafka来检索数据以及向微服务发送数据。我知道如
我想在此处添加一些代码,并从Flink中输出protobuf数据。 我正在使用Flink的Apache Kafka连接器,以便将
我能够执行将数据从spooldir传输到Hbase的操作,但是我的数据采用Json格式,并且我希望它们位于单独的列
我正在尝试使用我的kafka侦听器方法从SQL数据库中寻求偏移量。 我在代码中使用了registerSeekCallback方法,
我用Java生成数据并将其下沉到Kafka主题,之后我希望该数据沉入MongoDB。 当我通过JAVA将数据作为JSON发送
试图对流进行分组,聚合和抑制,从而导致- <pre><code>Caused by: java.lang.ClassCastException: class org.apache.kafka
我正在研究一种情况,我想要写入的主题与写入的数据库表之间存在多对一的关系。数据源提供了有关
有3个kafka服务器 在所有3台服务器上设置<code>/etc/hosts</code>。 <pre><code>192.168.0.1 kafka1 192.168.0.2 ka
我正在研究其中有2个群集的作品,可以将它们称为DC1和DC2,每个群集上都运行Mirrormaker 2。我在每个节点
我有三个节点的kafka群集。我向具有1个分区和复制因子3的kafka主题生成了消息。如果我的使用者的工作
我正在从Kafka看书,但消费者挂了电话: <pre><code>def produce(num, producer, topic_name): print(&#34;hello2&#34;)
我具有以下Avro架构: <pre><code> `{ &#34;name&#34;: &#34;ABC&#34;, &#34;type&#34;: &#34;record&#34;, &#3
我一生无法找到有关此方面的信息,如果这很明显,请原谅我。 我正在将Kafka代理的端口发布到我
关于Kafka中的确认模式,以下是我发现的2个文档: <ol> <li>参考文献1:<a href="https://docs.spring.io/spring-ka