spring-kafka

1熱

1答えて

Spring Kafka、組み込みカフカを使用したテスト

Servicetestと組み込みカフカでは、奇妙な動作が観察されています。 テストスポックテストで、我々はJUnitのルールKafkaEmbeddedを使用すると、次のようにbrokersAsStringを伝播： @ClassRule @Shared KafkaEmbedded embeddedKafka = new KafkaEmbedded(1) @Autowired KafkaLi

spring spring-boot apache-kafka spring-kafka 2016-07-29

---

0熱

1答えて

SpringBoot/spring-kafkaアプリケーションでAutowired KafkaTemplateがnullポインタを投げる

私は、Springブートアプリケーション内でspring-kafka KafkaTemplateを使用して、Kafkaトピックにメッセージを書き込もうとしています。 @Configuration @EnableKafka public class KafkaConfig { @Value("${kafka.broker.address}") private String

java spring spring-boot spring-kafka 2016-08-08

---

0熱

2答えて

初めてカフカ消費者がレコードを取得すると、多くのレコードのうちの1レコードしか取得できないのですか？

私はspring-kafkaとspring-kafka-testバージョン1.0.2.RELEASEを使用しています。 私のテストでは、私のアプリケーションは、KafkaTemplateとほとんどのデフォルトの設定を使ってEmbeddedKafkaインスタンスの1つのTopicPartionに100レコードを連続して送ります。 私はKafkaインスタンスからレコードを取得し、それらがすべて送信され

apache-kafka kafka-consumer-api spring-kafka 2016-08-11

---