使用Spring Boot创建Kafka主题
@Configuration
public class KafkaTopicConfiguration {
@Bean
public NewTopic createTopic(Topic topic) {
return TopicBuilder.name(topic.getTopicName())
.partitions(topic.getPartitions())
.replicas(topic.getReplicas())
.build();
}
}
@PostMapping("/api/v1/kafkatopic/")
public NewTopic createTopic(@RequestBody Topic topic)
{
return kt.createTopic(topic);
}
//kt being object of the Configuration Class
@Bean
public NewTopic createTopic() {
return TopicBuilder.name("test-topic")
.partitions(6)
.replicas(3)
.build();
}
共有1个答案
try (AdminClient client = AdminClient.create(kafkaAdmin.getConfigurationProperties()) {
...
}
-
我正在编程一个客户端工作与Kafka0.9。我想知道如何制造话题。这个答案：如何通过Java在Kafka中创建一个主题，与我所问的类似。除此之外，该解决方案仅适用于Kafka 0.8.2，这与Kafka 0.9的API有很大不同。
-
null camel-kafka中是否有任何配置，我们可以使用它来增加kafka主题分区计数？
-
我用Flink来读写来自不同Kafka主题的数据。具体来说，我使用的是FlinkKafkaConsumer和FlinkkafKapProducer。 我想知道是否有可能根据我程序中的逻辑或记录本身的内容，将我正在阅读和写作的Kafka主题更改为“即时”。 例如，如果读取带有新字段的记录，我希望创建一个新主题，并开始将带有该字段的记录转移到新主题。 谢谢。
-
我创建了一个具有REST Web服务和jpa依赖关系的Spring Boot应用程序。应用程序作为独立应用程序自行运行。我试图添加UI层使用vaadin作为一个单独的项目，使用sring引导项目的服务。有没有一种简单的方法可以使Spring Boot应用程序成为一个可以包含在其他项目中的库jar。 我搜索了论坛，发现一些建议不要使用Spring Boot，而是使用spring框架来创建库的线程。只
-
当尝试使用--bootstrap-server创建主题时，我得到异常“执行Kafka主题命令时出错：等待节点时超时”：- 然而，以下操作很好，使用--zookeeper：- 注意-我设置了Zookeeper仲裁和Kafka broker集群，每个集群在一台机器上包含3个实例（用于开发）
-
我正在使用jhipster kafka实现，它使用confluentinc/cp-kafka： 5.4.0映像，当我尝试使用环境变量“KAFKA_CREATE_TOPICS：”创建Kafka主题时，我没有收到任何错误，但主题没有被创建，我在想三种不同的方法来解决这个问题， 通过 docker 撰写文件上的命令创建主题。 将Kafka和动物园管理员的形象更改为另一个像沃尔斯特迈斯特形象的形象。 在