org.apache.kafka.streams.errors.StreamsException: Failed to rebalance


Solutions on the web

Solution icon of googlegroups
Failed to rebalance

Solution icon of googlegroups
via Google Groups by vivek sharma, 8 months ago
Failed to rebalance

Solution icon of googlegroups
via Google Groups by Unknown author, 7 months ago
Failed to rebalance

Solution icon of googlegroups
via Google Groups by vivek sharma, 7 months ago
Failed to rebalance

Solution icon of googlegroups
via Google Groups by Tianxiang Xiong, 7 months ago
Failed to rebalance

Solution icon of stackoverflow
via Stack Overflow by Samy
, 1 year ago
Failed to rebalance

Solution icon of googlegroups
via Google Groups by Tariq Mohammad, 3 months ago
Failed to rebalance

Solution icon of stackoverflow
stream-thread [StreamThread-1] Failed to rebalance

Solution icon of stackoverflow
stream-thread [StreamThread-1] Failed to rebalance

Stack trace

org.apache.kafka.streams.errors.StreamsException: Failed to
         rebalance
	at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:299)
	at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:218)
Caused by: java.lang.NullPointerException
	at org.rocksdb.RocksDB.put(RocksDB.java:432)
	at org.apache.kafka.streams.state.internals.RocksDBStore.putInternal(RocksDBStore.java:298)
	at org.apache.kafka.streams.state.internals.RocksDBStore.access$200(RocksDBStore.java:62)
	at org.apache.kafka.streams.state.internals.RocksDBStore$3.restore(RocksDBStore.java:205)
	at org.apache.kafka.streams.processor.internals.ProcessorStateManager.restoreActiveState(ProcessorStateManager.java:245)
	at org.apache.kafka.streams.processor.internals.ProcessorStateManager.register(ProcessorStateManager.java:210)
	at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.register(ProcessorContextImpl.java:116)
	at org.apache.kafka.streams.state.internals.RocksDBStore.init(RocksDBStore.java:201)
	at org.apache.kafka.streams.state.internals.MeteredKeyValueStore.init(MeteredKeyValueStore.java:85)
	at org.apache.kafka.streams.processor.internals.AbstractTask.initializeStateStores(AbstractTask.java:81)
	at org.apache.kafka.streams.processor.internals.StreamTask.<init>(StreamTask.java:115)
	at org.apache.kafka.streams.processor.internals.StreamThread.createStreamTask(StreamThread.java:550)
	at org.apache.kafka.streams.processor.internals.StreamThread.addStreamTasks(StreamThread.java:577)
	at org.apache.kafka.streams.processor.internals.StreamThread.access$000(StreamThread.java:68)
	at org.apache.kafka.streams.processor.internals.StreamThread$1.onPartitionsAssigned(StreamThread.java:123)
	at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.onJoinComplete(ConsumerCoordinator.java:222)
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$1.onSuccess(AbstractCoordinator.java:232)
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$1.onSuccess(AbstractCoordinator.java:227)
	at org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:133)
	at org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:107)
	at org.apache.kafka.clients.consumer.internals.RequestFuture$2.onSuccess(RequestFuture.java:182)
	at org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:133)
	at org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:107)
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:436)
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:422)
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:679)
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:658)
	at org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:167)
	at org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:133)
	at org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:107)
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.onComplete(ConsumerNetworkClient.java:426)
	at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:278)
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll(ConsumerNetworkClient.java:360)
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:224)
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:192)
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:163)
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:243)
	at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.ensurePartitionAssignment(ConsumerCoordinator.java:345)
	at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:977)
	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:937)
	at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:295)
	... 1 more

Write tip

You have a different solution? A short tip here would help you and many other users who saw this issue last week.

Users with the same issue

You are the first who have seen this exception. Write a tip to help other users and build your expert profile.