[jira] [Created] (KAFKA-9277) move all group state transition rules into their states

dengziming created KAFKA-9277: - Summary: move all group state transition rules into their states Key: KAFKA-9277 URL: https://issues.apache.org/jira/browse/KAFKA-9277 Project: Kafka Issue Type: I

Jenkins build is back to normal : kafka-trunk-jdk8 #4087

See

kafka upgrade 2.3.0 may cause tcp delay ack(Congestion Control)

Hi: I have submit a kafka jira https://issues.apache.org/jira/browse/KAFKA-9211 this describe after we upgrade kafka from 0.10.0.1 to 2.3.0 , it triggered tcp ack delay,and in wost situation, a 1KB message produce request may use 3500ms to g

Build failed in Jenkins: kafka-trunk-jdk11 #1005

See Changes: [wangguoz] KAFKA-9131: Remove dead code for handling timeout exception (#7635) [wangguoz] MINOR: Convert last streams join test to TTD (#) -- [...trunc

Build failed in Jenkins: kafka-2.4-jdk8 #99

See Changes: [bill] MINOR: Convert last streams join test to TTD (#) -- [...truncated 2.70 MB...] org.apache.kafka.streams.internals.KeyValueStoreFacadeTest > shouldRetu

[jira] [Created] (KAFKA-9276) Unclear warning due to empty throttled fetch response

Bob Barrett created KAFKA-9276: -- Summary: Unclear warning due to empty throttled fetch response Key: KAFKA-9276 URL: https://issues.apache.org/jira/browse/KAFKA-9276 Project: Kafka Issue Type: B

[jira] [Created] (KAFKA-9275) Print assignment and IP address in the log message when consumer leaves/removed from the group

Badai Aqrandista created KAFKA-9275: --- Summary: Print assignment and IP address in the log message when consumer leaves/removed from the group Key: KAFKA-9275 URL: https://issues.apache.org/jira/browse/KAFKA-9275

[jira] [Created] (KAFKA-9274) Gracefully handle timeout exceptions on Kafka Streams

Boyang Chen created KAFKA-9274: -- Summary: Gracefully handle timeout exceptions on Kafka Streams Key: KAFKA-9274 URL: https://issues.apache.org/jira/browse/KAFKA-9274 Project: Kafka Issue Type: I

Build failed in Jenkins: kafka-2.4-jdk8 #98

See Changes: -- [...truncated 8.17 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentWithNullReversForCompareKeyValueTimestampWithProducerRecord PASSE

Build failed in Jenkins: kafka-trunk-jdk8 #4086

See Changes: [github] MINOR: Cleanup redundancies in BaseRequestTest (#7735) -- [...truncated 5.57 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIf

[jira] [Created] (KAFKA-9273) Refactor AbstractJoinIntegrationTest and Sub-classes

Bill Bejeck created KAFKA-9273: -- Summary: Refactor AbstractJoinIntegrationTest and Sub-classes Key: KAFKA-9273 URL: https://issues.apache.org/jira/browse/KAFKA-9273 Project: Kafka Issue Type: Te

Jenkins build is back to normal : kafka-trunk-jdk11 #1004

See

Re: [DISCUSS] KIP-405: Kafka Tiered Storage

Hi Jun, Thanks for your reply. Currently, `listRemoteSegments` is called at the configured interval(not every second, defaults to 30secs). Storing remote log metadata in a strongly consistent store for S3 RSM is raised in PR-comment[1]. RLM invokes RSM at regular intervals and RSM can give remote

[jira] [Reopened] (KAFKA-9261) NPE when updating client metadata

[ https://issues.apache.org/jira/browse/KAFKA-9261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reopened KAFKA-9261: -- > NPE when updating client metadata > - > > Key: KAFKA-9261

Build failed in Jenkins: kafka-trunk-jdk8 #4085

See Changes: [github] KAFKA-8933; Fix NPE in DefaultMetadataUpdater after authentication [jason] KAFKA-9251; Describing a non consumer group with the Admin API hangs [github] Actually run the delete topic comma

Jenkins build is back to normal : kafka-2.3-jdk8 #149

See

[jira] [Created] (KAFKA-9272) Error when trying to connect to SSL port using PLAINTEXT is very confusing

Richard Wise created KAFKA-9272: --- Summary: Error when trying to connect to SSL port using PLAINTEXT is very confusing Key: KAFKA-9272 URL: https://issues.apache.org/jira/browse/KAFKA-9272 Project: Kafka

Re: [DISCUSS] KIP-405: Kafka Tiered Storage

Hi Jun and others. Jun, All these are really valid concerns. Probably we should think about backing implementations like S3 with a metadata storage whose consistency model and pricing is better that pure S3, maybe even a Kafka topic (I guess this might be something you refer to as push-based appro

[jira] [Created] (KAFKA-9271) Client hangs until timeout when SSL handshake fails

Richard Wise created KAFKA-9271: --- Summary: Client hangs until timeout when SSL handshake fails Key: KAFKA-9271 URL: https://issues.apache.org/jira/browse/KAFKA-9271 Project: Kafka Issue Type: B

Build failed in Jenkins: kafka-2.4-jdk8 #97

See Changes: [manikumar.reddy] Actually run the delete topic command in kafka.py (#7776) -- [...truncated 2.70 MB...] org.apache.kafka.streams.test.OutputVerifierTest > sho

Build failed in Jenkins: kafka-trunk-jdk11 #1003

See Changes: [github] KAFKA-8933; Fix NPE in DefaultMetadataUpdater after authentication [jason] KAFKA-9251; Describing a non consumer group with the Admin API hangs [github] Actually run the delete topic comm