You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/10/17 20:07:00 UTC
[jira] [Updated] (KAFKA-8972) KafkaConsumer.unsubscribe could leave
inconsistent user rebalance callback state
[ https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Guozhang Wang updated KAFKA-8972:
---------------------------------
Summary: KafkaConsumer.unsubscribe could leave inconsistent user rebalance callback state (was: Toggle bulkloading hit NPE)
> KafkaConsumer.unsubscribe could leave inconsistent user rebalance callback state
> --------------------------------------------------------------------------------
>
> Key: KAFKA-8972
> URL: https://issues.apache.org/jira/browse/KAFKA-8972
> Project: Kafka
> Issue Type: Bug
> Affects Versions: 2.4.0
> Reporter: Boyang Chen
> Assignee: Boyang Chen
> Priority: Blocker
> Fix For: 2.4.0
>
>
> test `test_broker_type_bounce` could sometimes fail due to NPE in changelog restoration:
>
> ```
> [2019-09-30 15:22:43,574] ERROR stream-thread [SmokeTest-357607f6-655b-4b3c-ad3e-f5e5e19df83e-StreamThread-2] Encountered the following error during processing: (org.apache.kafka.streams.processor.internals.StreamThread)
> java.lang.NullPointerException
> at org.apache.kafka.streams.state.internals.RocksDBStore.toggleDbForBulkLoading(RocksDBStore.java:403)
> at org.apache.kafka.streams.state.internals.RocksDBStore$RocksDBBatchingRestoreCallback.onRestoreStart(RocksDBStore.java:650)
> at org.apache.kafka.streams.processor.internals.CompositeRestoreListener.onRestoreStart(CompositeRestoreListener.java:59)
> at org.apache.kafka.streams.processor.internals.StateRestorer.restoreStarted(StateRestorer.java:76)
> at org.apache.kafka.streams.processor.internals.StoreChangelogReader.startRestoration(StoreChangelogReader.java:205)
> at org.apache.kafka.streams.processor.internals.StoreChangelogReader.initialize(StoreChangelogReader.java:181)
> at org.apache.kafka.streams.processor.internals.StoreChangelogReader.restore(StoreChangelogReader.java:79)
> at org.apache.kafka.streams.processor.internals.TaskManager.updateNewAndRestoringTasks(TaskManager.java:327)
> at org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:863)
> at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:792)
> at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:761)```
> Seems to be some bug with dbAccessor initialization.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)