英文: Failed to start bean 'replyingTemplate'; nested exception is java.lang.IllegalStateExcep...
如何以编程方式获取主题权限 [Kafka,Java]
英文: How to programmatically get topics permissions [Kafka, Java] 问题 我正在实现高级 Kafka 健康检查。现在实现了“标准”健康检查...
处理Flink广播流中的大数据
英文: Process large data in flink broadcast stream 问题 我正在使用一个 Flink 流处理的 Java 应用程序,输入源是 Kafka。我的应用程序中总...
如何在Java中从由Kafka创建的_confluent-metrics主题中读取数据。
英文: How to read from the _confluent-metrics topic in Java which is created by kafka 问题 我想获取其中一个我的接收器...
Spring Boot与Spring Kafka的Rest API
英文: Spring boot Rest api with Spring Kafka 问题 我已经设计了一个Spring Boot REST API的ADD和GET方法。 @RestControlle...
Using Schema Registry from Confluent with Avro and Kafka in Spring Boot Applications
英文: Using Schema Registry from Confluent with Avro and Kafka in Spring Boot Applications 问题 首先,我必须说我...
设置客户端端的SASL身份验证以连接两个不同的Kafka集群。
英文: Setup client side SASL authentication to connect with two different kafka clusters 问题 我有一个Spring...
Spring Kafka MessageListenerContainer Resume/Pause # spring-kafka
英文: Spring Kafka MessageListenerContainer Resume/Pause # spring-kafka 问题 由于原生的 KafkaConsumer 不是线程安全的...
Kafka Stream 用于消费 JSON 并生产 Avro。
英文: Kafka Stream to consume JSON and Produce Avro 问题 请提供GitHub网址,以便我查看代码和所有需要完成的配置。提前致谢。 英文: As i am...
将 Avro GenericRecord 转换为 SpecificData 对象,同时将 Long 转换为 Instant。
英文: Convert Avro GenericRecord to SpecificData object while converting Long to Instant 问题 我正在尝试将从Kaf...
41