ericwuseattle

Any thoughts on this problem? Are more details needed?

unfortunately I do not have the evn was set up to testing in my hand right now, have you checked the hard code of partition count in the code, if...

> Given your configuration you're not using the sticky assignor as `fetch.min.bytes=1, fetch.wait.max.ms=500, fetch.error.backoff.ms=0, heartbeat.interval.ms=1000, enable.auto.commit=false, enable.partition.eof=false, enable.auto.offset.store=false, max.poll.interval.ms=3000, session.timeout.ms=3000` > > as the default `partition.assignment.strategy` doesn't include `cooperative-sticky` could...

> I'm not sure what's causing the timeout, but I'm sure we keep calling kafka poll in a timer infinitely. So increase into 10s it's working without any issue. >>...

  it's more like rk->rk_telemetry.client_instance_id is not valid value, the value is read from kafka broker(rd_kafka_buf_read_uuid(rkbuf, &rk->rk_telemetry.client_instance_id)) as response of GetTelemetrySubscriptions.