[
https://issues.apache.org/jira/browse/KAFKA-7209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560143#comment-16560143
]
Yogesh BG commented on KAFKA-7209:
----------------------------------
offsets.topic.replication.factor set to 1 then also i receive something like
below
{{ Received GroupCoordinator response
ClientResponse(receivedTimeMs=1532716985393, latencyMs=15, disconnected=false,
requestHeader=\{api_key=10,api_version=1,correlation_id=6157,client_id=ks_0_inst_THUNDER_METRICS-StreamThread-37-consumer},
responseBody=FindCoordinatorResponse(throttleTimeMs=0, errorMessage='null',
error=COORDINATOR_NOT_AVAILABLE, node=:-1 (id: -1 rack: null))) for group
aggregation-framework030_THUNDER_METRICS}}{{18:43:05.394
[ks_0_inst_THUNDER_LOG_L4-StreamThread-70] DEBUG
o.a.k.c.consumer.internals.Fetcher - Fetch READ_UNCOMMITTED at offset 0 for
partition THUNDER_LOG_L4_PC-17 returned fetch data (error=NONE,
highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions
= null, recordsSizeInBytes=0)}}
> Kafka stream does not rebalance when one node gets down
> -------------------------------------------------------
>
> Key: KAFKA-7209
> URL: https://issues.apache.org/jira/browse/KAFKA-7209
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 0.11.0.1
> Reporter: Yogesh BG
> Priority: Critical
>
> I use kafka streams 0.11.0.1session timeout 60000, retries to be int.max and
> backoff time default
>
> I have 3 nodes running kafka cluster of 3 broker
> and i am running the 3 kafka stream with same
> [application.id|http://application.id/]
> each node has one broker one kafka stream application
> everything works fine during setup
> i bringdown one node, so one kafka broker and one streaming app is down
> now i see exceptions in other two streaming apps and it never gets re
> balanced waited for hours and never comes back to norma
> is there anything am missing?
> i also tried looking into when one broker is down call stream.close, cleanup
> and restart this also doesn't help
> can anyone help me?
>
>
>
> One thing i observed lately is that kafka topics with partitions one gets
> reassigned but i have topics of 16 partitions and replication factor 3. It
> never settles up
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
