Skip to content

Commit 4ef0ba7

Browse files
author
Kishan Sairam Adapa
authored
chore: add operational caveat to live event listener doc (#89)
1 parent 7d5f42f commit 4ef0ba7

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

kafka-event-listener/src/main/java/org/hypertrace/core/kafka/event/listener/KafkaLiveEventListener.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,8 +18,13 @@
1818
* topic are consumed by this listener as every time we create a listener we consume from latest
1919
* offsets by design.
2020
*
21+
* <p>Operational Caveat: The listener subscribes to active partitions only, in case the partition
22+
* count changes once the listener is active, it will be opaque to those new partitions and will not
23+
* consume them. Only a new listener will go and fetch all active partitions hence it will be
24+
* required to restart the consumer application.
25+
*
2126
* <p>Typical usage of this listener is to back the remote caches to have lower latency of refresh
22-
* by generating respective information on kafka topics
27+
* by generating respective information on kafka topics.
2328
*/
2429
public class KafkaLiveEventListener<K, V> implements AutoCloseable {
2530
private final Future<Void> kafkaLiveEventListenerCallableFuture;

0 commit comments

Comments
 (0)