Question

Mocking SchemaRegistryClient in stream processor Consumer

score 451 · Answer 1 · 2020-12-16 21:38:49

451

Views

Mocking SchemaRegistryClient in stream processor Consumer

Published on 16 December 2020 at 21:38

score 1.3k · Answer 2 · 2020-12-16 19:13:35

1.3k

Views

Embedded Kafka not showing consumer offset

Published on 16 December 2020 at 19:13

score 899 · Answer 3 · 2021-04-21 09:48:09

899

Views

NPE Testing Kafka Producer Using Embedded Kafka

Published on 21 April 2021 at 09:48

score 358 · Answer 4 · 2018-11-01 08:21:14

358

Views

Testing with EmbeddedKafka - Test report

Published on 01 November 2018 at 08:21

score 1.9k · Answer 5 · 2021-06-02 11:53:33

1.9k

Views

Spring Cloud Stream deserializing invalid JSON from Kafka Topic

Published on 02 June 2021 at 11:53

score 270 · Answer 6 · 2021-06-09 23:11:51

270

Views

Listener not consuming message on Test with EmbeddedKafka Spring

Published on 09 June 2021 at 23:11

score 299 · Answer 7 · 2022-12-16 11:07:59

299

Views

Embedded Kafka test cases not considered in test case execution

Published on 16 December 2022 at 11:07

score 1.4k · Answer 8 · 2021-01-28 16:41:36

1.4k

Views

Unit test with EmbeddedKafka

Published on 28 January 2021 at 16:41

score 1.2k · Answer 9 · 2021-01-31 13:37:39

1.2k

Views

How to test Spring Kafka Streams

Published on 31 January 2021 at 13:37

score 186 · Answer 10 · 2022-05-23 08:22:29

186

Views

Spring Contracts: Stubs are runnning on port -1 + Failed to construct kafka producer

Published on 23 May 2022 at 08:22

score 427 · Answer 11 · 2022-11-19 04:06:44

427

Views

Spring EmbeddedKafka producer not waiting for consumer acknowledgement

Published on 19 November 2022 at 04:06

score 242 · Answer 12 · 2022-11-23 00:10:50

242

Views

Multiple SpringBootTests using EmbeddedKafka fails with "only one 'RetryTopicConfigurationSupport'"

Published on 23 November 2022 at 00:10

score 2.7k · Answer 13 · 2022-11-30 06:15:39

2.7k

Views

Spring Kafka 2.9.3 NoClassDefFound - AlterIsrRequest$Builder on EmbeddedKafka Start up

Published on 30 November 2022 at 06:15

score 261 · Answer 14 · 2022-12-09 15:16:42

261

Views

Using upgrade.from config in Kafka Streams is causing a "BindException: Address already in use" error in tests using embedded-kafka-schema-registry

Published on 09 December 2022 at 15:16

score 559 · Answer 15 · 2018-06-01 14:17:28

559

Views

Producer error in Scala Embedded Kafka with Kafka Streams

Published on 01 June 2018 at 14:17

score 200 · Answer 16 · 2018-07-26 15:48:05

200

Views

Kafka Streams: mix-and-match PAPI and DSL KTable not co-partitioning

Published on 26 July 2018 at 15:48

score 5.3k · Answer 17 · 2020-04-03 08:01:22

5.3k

Views

How to stop and start the Embedded Kafka in unit test?

Published on 03 April 2020 at 08:01

score 462 · Answer 18 · 2019-12-24 05:44:16

462

Views

How to increase RAM for embedded-kafka?

Published on 24 December 2019 at 05:44

score 2.6k · Answer 19 · 2019-10-13 19:34:02

2.6k

Views

Failed to create or validate data directory for EmbeddedKafkaBroker

Published on 13 October 2019 at 19:34

score 1.9k · Answer 20 · 2021-09-23 11:11:04

1.9k

Views

Integration test using EmbeddedKafka: ContainerTestUtil.waitForAssignment throws Expected 1 but got 0 partitions

Published on 23 September 2021 at 11:11

List Question

Mocking SchemaRegistryClient in stream processor Consumer

Embedded Kafka not showing consumer offset

NPE Testing Kafka Producer Using Embedded Kafka

Testing with EmbeddedKafka - Test report

Spring Cloud Stream deserializing invalid JSON from Kafka Topic

Listener not consuming message on Test with EmbeddedKafka Spring

Embedded Kafka test cases not considered in test case execution

Unit test with EmbeddedKafka

How to test Spring Kafka Streams

Spring Contracts: Stubs are runnning on port -1 + Failed to construct kafka producer

Spring EmbeddedKafka producer not waiting for consumer acknowledgement

Multiple SpringBootTests using EmbeddedKafka fails with "only one 'RetryTopicConfigurationSupport'"

Spring Kafka 2.9.3 NoClassDefFound - AlterIsrRequest$Builder on EmbeddedKafka Start up

Using upgrade.from config in Kafka Streams is causing a "BindException: Address already in use" error in tests using embedded-kafka-schema-registry

Producer error in Scala Embedded Kafka with Kafka Streams

Kafka Streams: mix-and-match PAPI and DSL KTable not co-partitioning

How to stop and start the Embedded Kafka in unit test?

How to increase RAM for embedded-kafka?

Failed to create or validate data directory for EmbeddedKafkaBroker

Integration test using EmbeddedKafka: ContainerTestUtil.waitForAssignment throws Expected 1 but got 0 partitions

Trending Questions

Popular # Hahtags

Popular Questions