我们将消息发送到Kafka主题，该主题通过骆驼路由发送到ActiveMQ主题，在那里一切都如预期的那样工作。但现在我们有了另一条路由，将消息数组从ActiveMQ主题发送到卡夫卡的另一个主题，也就是骆驼进入无限循环的地方。下面是我的路由XML。为什么这种类型的配置会导致无限循环？
<!--DEFINE KAFKA'S TOPCIS AS ENDPO
浏览 2提问于2018-07-14得票数 1
回答已采纳
1回答
我尝试使用Kafka 0.9.0 version Java API向Kafka topic发送XML data，因为0.9.0 version建议使用Java API而不是Scala API来获得更好的性能我的XML文件有关于5 MB data的，什么是XML，我可以用来读取XML文件并转换为字符串，然后将该字符串发送到Kafka主题。
或者我可以将XML转换为JSON数据并将其发送给Kafka吗？另外，我是否应该考虑将我的XML数据
浏览 1提问于2016-10-08得票数 0
我创建了如下所示的dataframe，其中使用了to_json()方法来创建JSON数组值。----------------------------------------------------------------------------------------+outgoingDF.selectExpr("CAST(Key as STRING) as key"
浏览 2提问于2020-12-02得票数 0
回答已采纳
1回答
我基本上想以字节数组的形式将avro模式中的元组发送到kafka主题。(BOLT1, new Fields("key"));Schema schema = avroObject.getSchema();
collector.emit(tuple, new Values(Obj.hashMD5(key), message
浏览 1提问于2015-03-12得票数 5
回答已采纳
0回答
我有一个Java应用程序，它流Twitter数据，并将它们发送到Kafka主题。它们最终由Spark streaming处理。谢谢你的帮助。
浏览 5提问于2017-06-18得票数 1
回答已采纳
@Bean return IntegrationFlows.from("kafkaRequestChannel")
.handle(Kafkaget(IntegrationMessageHeaderAccessor.SEQUENCE_NUMB
浏览 0提问于2017-09-29得票数 1
回答已采纳
我使用插件直接将卡夫卡消息传送到kairosDB中。
我在/lib文件夹中构建并成功地添加了插件，从日志中我看到插件正在运行，并连接到我的kafka主题中。在发送到这个主题的消息后，它不会继续使用插件，它似乎是停留在for (MessageAndMetadata<byte[], byte[]> messageAndMetadata : m_stream)上除了默认字符串解析器的主题名称之外，我没有在配置中更改任何内容，以匹配kafka</e
浏览 6提问于2017-11-17得票数 0
回答已采纳
我正在使用Java Eclipse创建一个事件管理系统，它将写入和读取JSON文件。这里我有创建一个新JSON文件的代码... String title = txtTitle.getText(); String day = (String) cboDate.getSelecte
浏览 25提问于2017-12-18得票数 0
回答已采纳
1回答
我需要在我的程序的一个实例的缓存中得到一个信息，为此，我想用Kafka来做Pub/Sub，但是我不知道如何发布并从我的订阅者那里得到响应。您知道允许这样做的模式和允许我这样做的服务吗？
浏览 9提问于2022-11-07得票数 -1
批处理之后，我需要向Kafka主题写入包含多个不同列的结果DataFrame。根据下面的火花文档，写入Kafka的Dataframe在模式中应该有以下强制列：
正如我前面提到的，我有更多的列有值，所以我有一个问题--如何正确地将整个DataFrame行作为一条消息从我的Spark应用程序发送到Kafka主题？我是否需要用一个值列(包含联接值)将所有列的所有值连接到新的DataFrame中，或者有更正确
浏览 0提问于2018-11-23得票数 0
回答已采纳
JSON消息正在由字符串使用者使用。我的produces发送两种类型的消息字符串和序列化的JSONpublic void consume(@NotNull Consumer
浏览 0提问于2020-02-13得票数 1
我使用Kafka作为队列，节点服务使用Kafka-Node生成和消费发送到Kafka主题的消息。 我一直在使用自制的分布式跟踪解决方案，但现在我们将转向Elastic APM。这似乎是为HTTP服务器量身定做的，但是我如何配置它才能与Kafka一起工作呢？我希望能够像下面这样跟踪事务:服务A向服务B发送HTTP请求，服务B向Kafka主题C生成HTTP请求，服务D从Kafka主题C消费该请求，服务D
浏览 28提问于2019-04-01得票数 5
回答已采纳
我是Apache Kafka技术的新手。我尝试使用python2.7将消息作为JSON对象发送到kafka主题，但是我得到了"AssertionError: Value must be bytes“错误。我可以成功地以字符串形式发送消息，我可以使用kafka-console-consumer.sh查看我的消息。我使用的是apache kafka 2.10-0.8.2.1版本。我在下面给出我的代码。from kafka imp
浏览 2提问于2016-12-14得票数 11
回答已采纳
我已经实现了一个Kafka Connect JDBC Source连接器，它连接到Oracle-Database，并将数据写入Kafka-Topic。目前，我已经在设置value.converter.schemas.enable=false的情况下设置了选项value.converter=org.apache.kafka.connect.json.JsonConverter该选项允许将JSON数据写入Kafka主题(顺便说一句，它工作得很好)，但不包括在将数据发
浏览 3提问于2021-02-18得票数 0
我正在用kafka-python将一些数据发送到Kafka主题。有一段时间，我很难将数据发送到Kafka主题，直到我发现，如果我短暂地延迟了代码，它就能工作。from kafka import KafkaProducer
producer = KafkaProducer(bootstrap_servers="localhost
浏览 0提问于2016-09-28得票数 7
1回答
我需要使用生产者动态创建的主题中的消息。.*“)中使用了主题模式方法，还设置了metadata.max.age.ms=3000。但显然，除非我将offset.auto.reset设置为最早，否则我无法实现这一点。
浏览 3提问于2019-12-09得票数 0
有一个单一的输入kafka主题，所有类型的数据都被抛到它上面。beam管道读取来自输入kafka主题的所有消息，并且必须根据密钥路由到不同的kafka主题。目前，KafkaIO不支持使用单个生产者写入多个主题。
浏览 15提问于2020-05-21得票数 0
回答已采纳
我可以在kafka中使用线程向单个主题发送消息吗？我开发了一个kafka生产者在春季启动发送消息到一个kafka主题，我需要知道是否有可能创建多个线程发送多个消息到一个主题。例如:在一个生产者中创建三个线程，同时将三个不同的消息从每个线程发送到单个kafka主题。有可能吗？make this有一些特定的配置吗？
浏览 1提问于2019-04-04得票数 2
相反，Kafka提供了它的API接口，它对于处理配置以及任务、工作人员等都非常有用。
如何将信息从SinkConnect
浏览 11提问于2021-04-26得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
