41 Commits

Author SHA1 Message Date
emanuel.trandafir
c5892eec6e BAEL-6552: small changes 2023-12-28 15:10:10 +01:00
emanueltrandafir1993
1ac666749b BAEL-6552: added test using the default configuration 2023-12-27 22:33:40 +01:00
emanuel.trandafir
6c736c0c88 BAEL-6552: kafka consumer's min/max fetch size 2023-12-27 18:29:16 +01:00
emanuel.trandafir
89817e2cda MKT-7258: optimize imports 2023-12-15 12:47:19 +01:00
emanuel.trandafir
0203ff1f0a BAEL-7258: increase pom versions 2023-12-15 12:44:12 +01:00
emanueltrandafir1993
40ef28a449 BAEL-7258: renaming 2023-12-09 19:20:16 +01:00
emanueltrandafir1993
5d13422a53 BAEL-7258: kafka listener without spring 2023-12-03 22:17:16 +01:00
Amol Gote
6e758b8438 The test names should be LiveTest not IntegrationTest, as per the other similar tests in this module. This naming is used to mark these tests as manually runnable only, since they are heavy tests that spin up a container, so we don't want them to be run as part of the automatic CI build. Same for the other tests. 2023-11-05 21:39:02 -05:00
Amol Gote
5d3f08d0e9 Fix the whitespace and newline issues - wuth code formatter 2023-11-05 21:32:49 -05:00
Amol Gote
80cd71fff3 Removing slf4j-log4j12, deleting log4j.properties and adding a standard src/test/resources/logback.xml, since the Kafka libraries use the logback SLF4J binding. 2023-11-04 18:33:09 -04:00
Amol Gote
2a6e561f76 Fixed unit test case failures 2023-11-04 18:09:21 -04:00
Amol Gote
2cecae1dfb Incorporate Review comments 2023-11-04 17:18:20 -04:00
Amol Gote
ddc5e0a5ef Update apache-kafka-2/src/test/java/com/baeldung/kafka/message/ordering/SinglePartitionIntegrationTest.java
Co-authored-by: Liam Williams <liam.williams@zoho.com>
2023-11-04 16:58:01 -04:00
Amol Gote
9c463c752b Update apache-kafka-2/src/test/java/com/baeldung/kafka/message/ordering/MultiplePartitionIntegrationTest.java
Co-authored-by: Liam Williams <liam.williams@zoho.com>
2023-11-04 16:57:47 -04:00
Amol Gote
3e2975196d Update apache-kafka-2/src/test/java/com/baeldung/kafka/message/ordering/ExtSeqWithTimeWindowIntegrationTest.java
Co-authored-by: Liam Williams <liam.williams@zoho.com>
2023-11-04 16:57:32 -04:00
Amol Gote
33b18c0ca4 Update apache-kafka-2/src/test/java/com/baeldung/kafka/message/ordering/ExtSeqWithTimeWindowIntegrationTest.java
Co-authored-by: Liam Williams <liam.williams@zoho.com>
2023-11-04 16:57:19 -04:00
Amol Gote
9a76f1a637 Update apache-kafka-2/src/test/java/com/baeldung/kafka/message/ordering/ExtSeqWithTimeWindowIntegrationTest.java
Co-authored-by: Liam Williams <liam.williams@zoho.com>
2023-11-04 16:57:02 -04:00
Amol Gote
e5da666432 Update apache-kafka-2/src/test/java/com/baeldung/kafka/message/ordering/MultiplePartitionIntegrationTest.java
Co-authored-by: Liam Williams <liam.williams@zoho.com>
2023-11-04 16:49:26 -04:00
Amol Gote
c2453a503f Update apache-kafka-2/src/test/java/com/baeldung/kafka/message/ordering/ExtSeqWithTimeWindowIntegrationTest.java
Co-authored-by: Liam Williams <liam.williams@zoho.com>
2023-11-04 16:46:17 -04:00
Amol Gote
1394665355 Update apache-kafka-2/src/test/java/com/baeldung/kafka/message/ordering/SinglePartitionIntegrationTest.java
Co-authored-by: Liam Williams <liam.williams@zoho.com>
2023-11-04 16:46:09 -04:00
Amol Gote
45bc3d94d4 Code Formatting 2023-11-02 20:18:19 -04:00
Amol Gote
1ab4017ad6 Issue fixes 2023-11-02 19:47:05 -04:00
Amol Gote
bfa7c53b54 Update apache-kafka-2/src/test/java/com/baeldung/kafka/message/ordering/MultiplePartitionIntegrationTest.java
Co-authored-by: Liam Williams <liam.williams@zoho.com>
2023-11-02 19:41:54 -04:00
Amol Gote
83d6d89db5 Update apache-kafka-2/src/test/java/com/baeldung/kafka/message/ordering/SinglePartitionIntegrationTest.java
Co-authored-by: Liam Williams <liam.williams@zoho.com>
2023-11-02 19:41:34 -04:00
Amol Gote
d0edfbc423 Update apache-kafka-2/src/test/java/com/baeldung/kafka/message/ordering/ExtSeqWithTimeWindowIntegrationTest.java
Co-authored-by: Liam Williams <liam.williams@zoho.com>
2023-11-02 19:41:27 -04:00
Amol Gote
667620821b Update apache-kafka-2/src/test/java/com/baeldung/kafka/message/ordering/ExtSeqWithTimeWindowIntegrationTest.java
Co-authored-by: Liam Williams <liam.williams@zoho.com>
2023-11-02 19:41:15 -04:00
Amol Gote
b7d743c629 Incorporated Review comments 2023-11-02 19:40:36 -04:00
Amol Gote
5b936c47a0 Message to User Event Rename 2023-10-17 19:39:27 -04:00
Amol Gote
baaef6bcf3 Added tests for External Sequence number with Time Window 2023-10-16 19:50:02 -04:00
Amol Gote
7c40b82bf9 Build Failure - Priority:3 Unit test class names need to end in UnitTest, integration tests with IntegrationTest, etc. 2023-10-15 19:30:29 -04:00
Amol Gote
d1d456e59a Removed insertPosition, renamed messageId to applicationIdentifier 2023-10-15 19:19:01 -04:00
Amol Gote
6d4e6886b3 Renamed Inser position to patition key 2023-10-15 18:42:20 -04:00
Amol Gote
c4aac70277 User Constants instead od repeatative strings 2023-10-15 15:46:35 -04:00
Amol Gote
8772eaa673 Single and Multiple Partition test. 2023-10-15 15:28:15 -04:00
Constantin
ed2f3234e6 BAEL-6612: How to subscribe a Kafka consumer to multiple topics (#14800)
* BAEL-6612: Subscribe consumer to multiple topics using Spring Kafka

* BAEL-6612: Subscribe consumer to multiple topics using Apache Kafka

* BAEL-6612: Revert README files

* BAEL-6612: Fix identation; remove static qualifier

* BAEL-6612: Fix identation; remove static qualifier
2023-10-06 23:21:30 -05:00
Gaetano Piazzolla
ef8a499819 JAVA-6405 | counting Partitions in a topic in two different ways. (#14233) 2023-06-17 09:55:59 -07:00
Avin Buricha
23917a110b BAEL-6416 | Article code (#14065) 2023-05-31 08:53:46 +05:30
Avin Buricha
9834fe1d21 BAEL-6409 | Article code (#14135)
* BAEL-6409 | Article code

* Compilation fix
2023-05-31 08:45:00 +05:30
Gaetano Piazzolla
3fce001db6 BAEL-6493 - Read last N messages from a Kafka Topic (#14020) 2023-05-15 12:16:21 -07:00
Avin Buricha
4a9e72664c BAEL-6410 (#13919)
* BAEL-6410 | Article code

* Adding consumer code for article
2023-05-06 08:53:31 +05:30
Tapan Avasthi
4e18fd0aa9 BAEL-5680: Guide to Check if Apache Kafka Server is Running (#12600)
Co-authored-by: Tapan Avasthi <tavasthi@Tapans-MacBook-Air.local>
2022-08-17 21:52:06 -05:00