1回答
, String> reactiveKafkaProducerTemplate) { Suppressed: reactor.core.publisher.FluxOnAssemblyat reacto
浏览 18提问于2022-01-24得票数 1
回答已采纳
我们需要一个关于如何用ReactiveKafkaConsumerTemplate和ReactiveKafkaProducerTemplate测试embedded-kafka-broker的示例。;import org.apache.kafka.connect.json.JsonSerializerimport org.junit.jupiter.api.BeforeEach;
import org.junit
浏览 4提问于2021-06-23得票数 1
我刚开始使用Reactor Kafka。我想知道什么时候和为什么使用而不是KafkaSender，这可以在官方的反应堆卡夫卡参考指南中找到？
浏览 21提问于2019-07-31得票数 0
回答已采纳
我正在使用Spring Kafka 1.1.2-RELEASE和Spring Boot 1.5.0 RC，并且我已经配置了一个自定义的值序列化/反序列化类来扩展org.springframework.kafka.support.serializer.JsonSerializer/org.springframework.kafka.support.serializer.JsonDeserializer。
浏览 19提问于2017-01-25得票数 7
回答已采纳
1回答
我在spring应用程序中使用spring发送数据主题。我需要从oracle表中获取数据并发送。即
目前，我正在发送个人公司obj，因此将密钥定义如下
companyKafkaTemplate.send(COMPANY_TOPIC,this.getKey(company), compan
浏览 0提问于2019-06-20得票数 2
1回答
有谁有一个长期运行的反应式Kafka消费者的例子吗？https://github.com/reactor/reactor-kafka.git中的SampleConsumer在订阅后退出，即expected.But我需要持续接收来自我们的主题的消息，并且在出现故障我确实通过https://github.com/CollaborationInEncapsulation/s1p-reactor-netty-kafka</em
浏览 20提问于2020-10-11得票数 0
我想知道Spring-Kafka的替代方案。
我在我的应用程序中使用了集成在Spring中的Kafka。我想探索任何可用的替代库。如果库之间共享比较分析，那将是很好的。
浏览 0提问于2019-05-17得票数 1
1回答
在之后，我创建了一个生产者方法private ReactiveKafkaProducerTemplate<String, String> kafkaTemplate;
Map<String, Object> props = new HashMap<>();当我等待更长时间(~3-4分钟)，发送者将失败
org.apache.kafka.co
浏览 1提问于2021-05-21得票数 0
我有以下配置： image: provectuslabs/kafka-ui logging:_0_NAME=local - KAFKA_CLUSTERS_0_ZOOKEEPER=ssl-zookeeper=2181
- KAFKA_CLUSTERS_0_PROP
浏览 10提问于2022-06-13得票数 0
回答已采纳
(JsonSerializer.java:185) ~[spring-kafka-2.7.6.jar:2.7.6] at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:886) ~[
浏览 410提问于2021-09-12得票数 0
下面是引发错误的日志的一部分：at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1115)
at reactor.kafka.receiver.internals.DefaultKafka
浏览 0提问于2019-07-15得票数 4
我们有一个集成了Project Reactor的Spring cloud Stream应用程序。$OnAssemblyException: reactor.core.publisher.Flux.doOnNextreactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:120)
at <em
浏览 258提问于2021-05-13得票数 0
就像@KafkaListener在阻止Kafka一样-它正在等待新的消息public class KafkaConsumerstatic final String BOOTSTRAP_SERVERS = "localhost:9092";
private static final String TOPIC = "Kafka_Example
浏览 4提问于2019-04-09得票数 3
;import reactor.kafka.receiver.KafkaReceiver;import reactor.kafka.sender.KafkaSender;impor
浏览 0提问于2021-07-11得票数 1
我们的应用程序使用springBootVersion = 2.0.4.RELEASE和compile('io.projectreactor.kafka:reactor-kafka:1.0.1.RELEASE我们拥有的Kafka代理的版本是1.0.1。当我们通过创建reactor.kafka.sender.SenderRecord间歇性地向Kafka发送消息时，在响应Kafka时，当查找reactor.kafka</e
浏览 154提问于2019-02-13得票数 1
回答已采纳
1回答
当尝试在kafka上生成消息时，不断获得log:reactor.core.Exceptions$ErrorCallbackNotImplemented: org.apache.kafka.common.errors.TimeoutExceptionCaused by: org.apache.kafka.common.errors.TimeoutException: Topic topic not present in metadata after我已经确保我在生产者项目中有杰克逊核心，杰克逊数据库和Kafka</e
浏览 1068提问于2021-07-09得票数 0
import org.apache.kafka.clients.consumer.ConsumerConfigimport reactor.kafka.receiver.KafkaReceiver
import reactor.kafka.receiver.Rec
浏览 12提问于2020-08-05得票数 1
试图获取泉云数据流在Kubernetes中工作，当Source试图向kafka发送消息时出现错误。当我使用兔子MQ.Kafka服务器版本Kafka2.1.0时，相同的代码运行良好。at reactor.core.publisher.Mono.subscribe(Mono.java:3694)
at reactor.core.publisher.FluxConcatMapat reactor.core.publisher.FluxPeek$PeekSubscriber.on
浏览 3提问于2019-11-19得票数 0
回答已采纳
2回答
.subscribe();日志：at reactor.kafka.receiver.ReceiverOptions.subscriber(ReceiverOptions.java:385) ~[reactor-kafka-1.3.4.jar:1.3.4]
at reactor.kafka.receiver.internals.ConsumerEv
浏览 51提问于2021-06-11得票数 0
回答已采纳
我正在尝试使用@EnableKafka和@KafkaListener注释为反应式Kafka消费者编写Spring引导应用程序。我已经配置了我的kafka代理在不同的机器上。</groupId> <version>1.0.0.RELEASE</version>
</dependency只有带有EnableKafka和KafkaL
浏览 70提问于2018-06-08得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
