[jira] [Commented] (KAFKA-16263) Add Kafka Streams docs about available listeners/callback
[ https://issues.apache.org/jira/browse/KAFKA-16263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868808#comment-17868808 ] Matthias J. Sax commented on KAFKA-16263: - It seems [~brandboat] and [~w4lt] are not interested any longer to work on it, so I would say, feel free to pick it up. > Add Kafka Streams docs about available listeners/callback > - > > Key: KAFKA-16263 > URL: https://issues.apache.org/jira/browse/KAFKA-16263 > Project: Kafka > Issue Type: Task > Components: docs, streams >Reporter: Matthias J. Sax >Assignee: Kuan Po Tseng >Priority: Minor > Labels: beginner, newbie > > Kafka Streams allows to register all kind of listeners and callback (eg, > uncaught-exception-handler, restore-listeners, etc) but those are not in the > documentation. > A good place might be > [https://kafka.apache.org/documentation/streams/developer-guide/running-app.html] > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (KAFKA-16263) Add Kafka Streams docs about available listeners/callback
[ https://issues.apache.org/jira/browse/KAFKA-16263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868370#comment-17868370 ] zhengke zhou commented on KAFKA-16263: -- Hi [~mjsax], Can i pick up this ticket? > Add Kafka Streams docs about available listeners/callback > - > > Key: KAFKA-16263 > URL: https://issues.apache.org/jira/browse/KAFKA-16263 > Project: Kafka > Issue Type: Task > Components: docs, streams >Reporter: Matthias J. Sax >Assignee: Kuan Po Tseng >Priority: Minor > Labels: beginner, newbie > > Kafka Streams allows to register all kind of listeners and callback (eg, > uncaught-exception-handler, restore-listeners, etc) but those are not in the > documentation. > A good place might be > [https://kafka.apache.org/documentation/streams/developer-guide/running-app.html] > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (KAFKA-16263) Add Kafka Streams docs about available listeners/callback
[ https://issues.apache.org/jira/browse/KAFKA-16263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854821#comment-17854821 ] Matthias J. Sax commented on KAFKA-16263: - [~brandboat] [~w4lt] – any updates on this ticket? > Add Kafka Streams docs about available listeners/callback > - > > Key: KAFKA-16263 > URL: https://issues.apache.org/jira/browse/KAFKA-16263 > Project: Kafka > Issue Type: Task > Components: docs, streams >Reporter: Matthias J. Sax >Assignee: Kuan Po Tseng >Priority: Minor > Labels: beginner, newbie > > Kafka Streams allows to register all kind of listeners and callback (eg, > uncaught-exception-handler, restore-listeners, etc) but those are not in the > documentation. > A good place might be > [https://kafka.apache.org/documentation/streams/developer-guide/running-app.html] > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (KAFKA-16263) Add Kafka Streams docs about available listeners/callback
[ https://issues.apache.org/jira/browse/KAFKA-16263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838727#comment-17838727 ] Matthias J. Sax commented on KAFKA-16263: - Yes, these are the handlers this ticket refers do. > Add Kafka Streams docs about available listeners/callback > - > > Key: KAFKA-16263 > URL: https://issues.apache.org/jira/browse/KAFKA-16263 > Project: Kafka > Issue Type: Task > Components: docs, streams >Reporter: Matthias J. Sax >Assignee: Kuan Po Tseng >Priority: Minor > Labels: beginner, newbie > > Kafka Streams allows to register all kind of listeners and callback (eg, > uncaught-exception-handler, restore-listeners, etc) but those are not in the > documentation. > A good place might be > [https://kafka.apache.org/documentation/streams/developer-guide/running-app.html] > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (KAFKA-16263) Add Kafka Streams docs about available listeners/callback
[ https://issues.apache.org/jira/browse/KAFKA-16263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837762#comment-17837762 ] Walter Hernandez commented on KAFKA-16263: -- Are you referring to: * {{[setGlobalStateRestoreListener|https://kafka.apache.org/37/javadoc/org/apache/kafka/streams/KafkaStreams.html#setGlobalStateRestoreListener(org.apache.kafka.streams.processor.StateRestoreListener)]}} * {{[setStandbyUpdateListener|https://kafka.apache.org/37/javadoc/org/apache/kafka/streams/KafkaStreams.html#setStandbyUpdateListener(org.apache.kafka.streams.processor.StandbyUpdateListener)]}} * {{[setStateListener|https://kafka.apache.org/37/javadoc/org/apache/kafka/streams/KafkaStreams.html#setStateListener(org.apache.kafka.streams.KafkaStreams.StateListener)]}} ** An app can set a single [{{KafkaStreams.StateListener}}|https://kafka.apache.org/37/javadoc/org/apache/kafka/streams/KafkaStreams.StateListener.html] so that the app is notified when state changes. {{}} * {{[setUncaughtExceptionHandler|https://kafka.apache.org/37/javadoc/org/apache/kafka/streams/KafkaStreams.html#setUncaughtExceptionHandler(org.apache.kafka.streams.errors.StreamsUncaughtExceptionHandler)]}} ** Set the handler invoked when an internal [{{stream}}|https://kafka.apache.org/37/javadoc/org/apache/kafka/streams/StreamsConfig.html#NUM_STREAM_THREADS_CONFIG] There's also this really nice tutorial on the uncaught-exception-handler feature: [https://github.com/bbejeck/streams-uncaught-exceptions-workshop] > Add Kafka Streams docs about available listeners/callback > - > > Key: KAFKA-16263 > URL: https://issues.apache.org/jira/browse/KAFKA-16263 > Project: Kafka > Issue Type: Task > Components: docs, streams >Reporter: Matthias J. Sax >Assignee: Kuan Po Tseng >Priority: Minor > Labels: beginner, newbie > > Kafka Streams allows to register all kind of listeners and callback (eg, > uncaught-exception-handler, restore-listeners, etc) but those are not in the > documentation. > A good place might be > [https://kafka.apache.org/documentation/streams/developer-guide/running-app.html] > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (KAFKA-16263) Add Kafka Streams docs about available listeners/callback
[ https://issues.apache.org/jira/browse/KAFKA-16263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837760#comment-17837760 ] Walter Hernandez commented on KAFKA-16263: -- Are you referring to: {{void}} {{[setGlobalStateRestoreListener|https://kafka.apache.org/37/javadoc/org/apache/kafka/streams/KafkaStreams.html#setGlobalStateRestoreListener(org.apache.kafka.streams.processor.StateRestoreListener)]([StateRestoreListener|https://kafka.apache.org/37/javadoc/org/apache/kafka/streams/processor/StateRestoreListener.html] globalStateRestoreListener)}} Set the listener which is triggered whenever a [{{StateStore}}|https://kafka.apache.org/37/javadoc/org/apache/kafka/streams/processor/StateStore.html] is being restored in order to resume processing. {{void}} {{[setStandbyUpdateListener|https://kafka.apache.org/37/javadoc/org/apache/kafka/streams/KafkaStreams.html#setStandbyUpdateListener(org.apache.kafka.streams.processor.StandbyUpdateListener)]([StandbyUpdateListener|https://kafka.apache.org/37/javadoc/org/apache/kafka/streams/processor/StandbyUpdateListener.html] standbyListener)}} Set the listener which is triggered whenever a standby task is updated {{void}} {{[setStateListener|https://kafka.apache.org/37/javadoc/org/apache/kafka/streams/KafkaStreams.html#setStateListener(org.apache.kafka.streams.KafkaStreams.StateListener)]([KafkaStreams.StateListener|https://kafka.apache.org/37/javadoc/org/apache/kafka/streams/KafkaStreams.StateListener.html] listener)}} An app can set a single [{{KafkaStreams.StateListener}}|https://kafka.apache.org/37/javadoc/org/apache/kafka/streams/KafkaStreams.StateListener.html] so that the app is notified when state changes. {{}} {{void}} {{[setUncaughtExceptionHandler|https://kafka.apache.org/37/javadoc/org/apache/kafka/streams/KafkaStreams.html#setUncaughtExceptionHandler(org.apache.kafka.streams.errors.StreamsUncaughtExceptionHandler)]([StreamsUncaughtExceptionHandler|https://kafka.apache.org/37/javadoc/org/apache/kafka/streams/errors/StreamsUncaughtExceptionHandler.html] userStreamsUncaughtExceptionHandler)}} Set the handler invoked when an internal [{{stream}}|https://kafka.apache.org/37/javadoc/org/apache/kafka/streams/StreamsConfig.html#NUM_STREAM_THREADS_CONFIG] {{}} {{}} There's also this really nice tutorial on the uncaught-exception-handler feature: [https://github.com/bbejeck/streams-uncaught-exceptions-workshop] > Add Kafka Streams docs about available listeners/callback > - > > Key: KAFKA-16263 > URL: https://issues.apache.org/jira/browse/KAFKA-16263 > Project: Kafka > Issue Type: Task > Components: docs, streams >Reporter: Matthias J. Sax >Assignee: Kuan Po Tseng >Priority: Minor > Labels: beginner, newbie > > Kafka Streams allows to register all kind of listeners and callback (eg, > uncaught-exception-handler, restore-listeners, etc) but those are not in the > documentation. > A good place might be > [https://kafka.apache.org/documentation/streams/developer-guide/running-app.html] > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (KAFKA-16263) Add Kafka Streams docs about available listeners/callback
[ https://issues.apache.org/jira/browse/KAFKA-16263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17831695#comment-17831695 ] Matthias J. Sax commented on KAFKA-16263: - Absolutely. If a ticket is not assigned to anybody, feel free to self-assign to yourself and pick it up. > Add Kafka Streams docs about available listeners/callback > - > > Key: KAFKA-16263 > URL: https://issues.apache.org/jira/browse/KAFKA-16263 > Project: Kafka > Issue Type: Task > Components: docs, streams >Reporter: Matthias J. Sax >Assignee: Kuan Po Tseng >Priority: Minor > Labels: beginner, newbie > > Kafka Streams allows to register all kind of listeners and callback (eg, > uncaught-exception-handler, restore-listeners, etc) but those are not in the > documentation. > A good place might be > [https://kafka.apache.org/documentation/streams/developer-guide/running-app.html] > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (KAFKA-16263) Add Kafka Streams docs about available listeners/callback
[ https://issues.apache.org/jira/browse/KAFKA-16263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827779#comment-17827779 ] Kuan Po Tseng commented on KAFKA-16263: --- May I take over this issue ? I'm quite interested in Kafka Streams :) > Add Kafka Streams docs about available listeners/callback > - > > Key: KAFKA-16263 > URL: https://issues.apache.org/jira/browse/KAFKA-16263 > Project: Kafka > Issue Type: Task > Components: docs, streams >Reporter: Matthias J. Sax >Priority: Minor > Labels: beginner, newbie > > Kafka Streams allows to register all kind of listeners and callback (eg, > uncaught-exception-handler, restore-listeners, etc) but those are not in the > documentation. > A good place might be > [https://kafka.apache.org/documentation/streams/developer-guide/running-app.html] > -- This message was sent by Atlassian Jira (v8.20.10#820010)