使用 Kafka Stream Processor 进行用户主题管理 API
User topic management using Kafka Stream Processor API
我刚开始接触 kafka。我经历了 this。它只说 data/topic 管理 kafka 流 DSL。任何人都可以共享任何 link 用于 kafka 流的处理器 API 的相同类型的数据管理吗？我对处理器的用户和内部主题管理特别感兴趣 API。
TopologyBuilder builder = new TopologyBuilder();
// add the source processor node that takes Kafka topic "source-topic" as input
builder.addSource("Source", "source-topic")
在流处理器开始使用输入数据之前，从哪里用输入数据填充这个源主题？
简而言之，我们可以使用流写入 kafka“Source”主题，就像生产者写入主题一样吗？还是流仅用于主题的并行消费？
我相信我们应该，因为“Kafka 的 Streams API 建立在 Kafka 的生产者和消费者客户之上”。
您可以使用 JXL(Java Excel API) 编写一个从 excel 文件写入 kafka 主题的生产者。
然后创建一个 kafka 流应用程序来使用该主题并生成另一个主题。
您可以使用 context.getTopic() 来获取处理器正在接收的主题。
然后在 process() 函数中设置多个 if 语句来调用该主题的流程逻辑。
是的，您必须使用 KafkaProducer 为提供给 KStream 的源主题生成输入。
但是，可以通过
填充中间主题
KafkaStreams#toKafkaStreams#through
我刚开始接触 kafka。我经历了 this。它只说 data/topic 管理 kafka 流 DSL。任何人都可以共享任何 link 用于 kafka 流的处理器 API 的相同类型的数据管理吗？我对处理器的用户和内部主题管理特别感兴趣 API。
TopologyBuilder builder = new TopologyBuilder();
// add the source processor node that takes Kafka topic "source-topic" as input
builder.addSource("Source", "source-topic")
在流处理器开始使用输入数据之前，从哪里用输入数据填充这个源主题？
简而言之，我们可以使用流写入 kafka“Source”主题，就像生产者写入主题一样吗？还是流仅用于主题的并行消费？ 我相信我们应该，因为“Kafka 的 Streams API 建立在 Kafka 的生产者和消费者客户之上”。
您可以使用 JXL(Java Excel API) 编写一个从 excel 文件写入 kafka 主题的生产者。 然后创建一个 kafka 流应用程序来使用该主题并生成另一个主题。 您可以使用 context.getTopic() 来获取处理器正在接收的主题。 然后在 process() 函数中设置多个 if 语句来调用该主题的流程逻辑。
是的，您必须使用 KafkaProducer 为提供给 KStream 的源主题生成输入。
但是，可以通过
填充中间主题KafkaStreams#toKafkaStreams#through