iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Issue fixes

Browse Source
This commit is contained in:
Amol Gote 2023-11-02 19:47:05 -04:00
parent bfa7c53b54
commit 1ab4017ad6
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
apache-kafka-2/src/test/java/com/baeldung/kafka/message/ordering/ExtSeqWithTimeWindowIntegrationTest.java
View File

@ -35,11 +35,11 @@ public class ExtSeqWithTimeWindowIntegrationTest {
private static KafkaProducer<Long, UserEvent> producer; private static KafkaProducer<Long, UserEvent> producer;
private static KafkaConsumer<Long, UserEvent> consumer; private static KafkaConsumer<Long, UserEvent> consumer;
private static final Duration TIMEOUT_WAIT_FOR_MESSAGES = Duration.ofSeconds(5); private static final Duration TIMEOUT_WAIT_FOR_MESSAGES = Duration.ofSeconds(5);
private static final long BUFFER_PERIOD_NS = 5000L * 1000000; // 5000 milliseconds converted to nanoseconds
@Container
private static final long BUFFER_PERIOD_NS = Duration.ofSeconds(5).toNanos(); private static final long BUFFER_PERIOD_NS = Duration.ofSeconds(5).toNanos();
@Container
private static final KafkaContainer KAFKA_CONTAINER = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:latest"));
@BeforeAll @BeforeAll
static void setup() throws ExecutionException, InterruptedException { static void setup() throws ExecutionException, InterruptedException {
KAFKA_CONTAINER.addExposedPort(9092); KAFKA_CONTAINER.addExposedPort(9092);