You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ab...@apache.org on 2020/11/18 07:06:01 UTC
[kafka] branch trunk updated (6bbf69f -> 5899f5f)
This is an automated email from the ASF dual-hosted git repository.
ableegoldman pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 6bbf69f KAFKA-10497 Convert group coordinator metadata schemas to use generat… (#9318)
add 5899f5f KAFKA-9331: Add a streams specific uncaught exception handler (#9487)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/KafkaStreams.java | 213 +++++++++++++++-----
...r.java => StreamsUncaughtExceptionHandler.java} | 30 +--
.../processor/internals/GlobalStreamThread.java | 16 +-
.../streams/processor/internals/StreamThread.java | 78 +++++---
.../internals/StreamsPartitionAssignor.java | 14 +-
.../internals/StreamsRebalanceListener.java | 7 +
.../internals/assignment/AssignmentInfo.java | 2 +
.../internals/assignment/AssignorError.java | 4 +-
.../StreamsAssignmentProtocolVersions.java | 4 +-
.../internals/assignment/SubscriptionInfo.java | 10 +-
.../common/message/SubscriptionInfoData.json | 7 +-
.../org/apache/kafka/streams/KafkaStreamsTest.java | 29 ++-
.../EOSUncleanShutdownIntegrationTest.java | 6 +-
.../integration/EosBetaUpgradeIntegrationTest.java | 3 +-
.../streams/integration/EosIntegrationTest.java | 1 +
.../FineGrainedAutoResetIntegrationTest.java | 10 +-
.../KStreamRepartitionIntegrationTest.java | 14 +-
.../integration/QueryableStateIntegrationTest.java | 1 +
.../integration/RegexSourceIntegrationTest.java | 5 +
.../integration/StandbyTaskEOSIntegrationTest.java | 5 +
...amsUncaughtExceptionHandlerIntegrationTest.java | 220 +++++++++++++++++++++
.../integration/SuppressionIntegrationTest.java | 2 +-
.../internals/GlobalStreamThreadTest.java | 6 +-
...HandlingSourceTopicDeletionIntegrationTest.java | 1 +
...ghAvailabilityStreamsPartitionAssignorTest.java | 2 +-
.../processor/internals/StreamThreadTest.java | 77 ++++++--
.../internals/StreamsPartitionAssignorTest.java | 2 +-
.../internals/StreamsRebalanceListenerTest.java | 18 ++
.../internals/assignment/AssignmentTestUtils.java | 6 +-
.../internals/assignment/SubscriptionInfoTest.java | 62 ++++--
.../streams/tests/BrokerCompatibilityTest.java | 5 +-
.../apache/kafka/streams/tests/EosTestClient.java | 4 +-
.../kafka/streams/tests/ShutdownDeadlockTest.java | 9 +-
.../kafka/streams/tests/SmokeTestClient.java | 7 +-
.../tests/StreamsBrokerDownResilienceTest.java | 5 +-
.../streams/tests/StreamsStandByReplicaTest.java | 5 +-
.../kafka/streams/tests/StreamsUpgradeTest.java | 12 +-
.../tests/streams/streams_upgrade_test.py | 4 +-
38 files changed, 717 insertions(+), 189 deletions(-)
copy streams/src/main/java/org/apache/kafka/streams/errors/{DeserializationExceptionHandler.java => StreamsUncaughtExceptionHandler.java} (56%)
create mode 100644 streams/src/test/java/org/apache/kafka/streams/integration/StreamsUncaughtExceptionHandlerIntegrationTest.java