[jira] [Updated] (KAFKA-7558) Dependency on __consumer_offsets at connection time

[ https://issues.apache.org/jira/browse/KAFKA-7558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Rykov updated KAFKA-7558: -- Description: It looks like currently(in version 2.0.0) consumer's ability to receive messages depends o

[jira] [Created] (KAFKA-7558) Ability for consumer to indicate no intention to commit

Alex Rykov created KAFKA-7558: - Summary: Ability for consumer to indicate no intention to commit Key: KAFKA-7558 URL: https://issues.apache.org/jira/browse/KAFKA-7558 Project: Kafka Issue Type: I

[jira] [Updated] (KAFKA-7534) Error during CachingKeyValueStore.flush may not allow RocksDB to close

[ https://issues.apache.org/jira/browse/KAFKA-7534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7534: --- Fix Version/s: 1.1.2 1.0.3 > Error during CachingKeyValueStore.flush may n

[jira] [Commented] (KAFKA-7534) Error during CachingKeyValueStore.flush may not allow RocksDB to close

[ https://issues.apache.org/jira/browse/KAFKA-7534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665739#comment-16665739 ] ASF GitHub Bot commented on KAFKA-7534: --- mjsax closed pull request #5833: KAFKA-753

[jira] [Commented] (KAFKA-7557) optimize LogManager.truncateFullyAndStartAt()

[ https://issues.apache.org/jira/browse/KAFKA-7557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665737#comment-16665737 ] Jun Rao commented on KAFKA-7557: To improve this, instead of calling Log.deleteSnapshots

[jira] [Created] (KAFKA-7557) optimize LogManager.truncateFullyAndStartAt()

Jun Rao created KAFKA-7557: -- Summary: optimize LogManager.truncateFullyAndStartAt() Key: KAFKA-7557 URL: https://issues.apache.org/jira/browse/KAFKA-7557 Project: Kafka Issue Type: Bug Affects V

[jira] [Resolved] (KAFKA-7352) KIP-368: Allow SASL Connections to Periodically Re-Authenticate

[ https://issues.apache.org/jira/browse/KAFKA-7352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-7352. --- Resolution: Fixed Reviewer: Rajini Sivaram > KIP-368: Allow SASL Connections to Periodi

[jira] [Updated] (KAFKA-7548) KafkaConsumer should not throw away already fetched data for paused partitions.

[ https://issues.apache.org/jira/browse/KAFKA-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mayuresh Gharat updated KAFKA-7548: --- Description: Today when we call KafkaConsumer.poll(), it will fetch data from Kafka asynchro

[jira] [Updated] (KAFKA-7548) KafkaConsumer should not throw away already fetched data for paused partitions.

[ https://issues.apache.org/jira/browse/KAFKA-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mayuresh Gharat updated KAFKA-7548: --- Description: In KafkaConsumer, when we do a poll, we fetch data asynchronously from kafka br

[jira] [Updated] (KAFKA-7548) KafkaConsumer should not throw away already fetched data for paused partitions.

[ https://issues.apache.org/jira/browse/KAFKA-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mayuresh Gharat updated KAFKA-7548: --- Description: In KafkaConsumer, when we do a poll, we fetch data asynchronously from kafka br

[jira] [Updated] (KAFKA-7548) KafkaConsumer should not throw away already fetched data for paused partitions.

[ https://issues.apache.org/jira/browse/KAFKA-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mayuresh Gharat updated KAFKA-7548: --- Description: In KafkaConsumer, when we do a poll, we fetch data asynchronously from kafka br

[jira] [Commented] (KAFKA-7556) KafkaConsumer.beginningOffsets does not return actual first offsets

[ https://issues.apache.org/jira/browse/KAFKA-7556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665433#comment-16665433 ] Mayuresh Gharat commented on KAFKA-7556: One more question, did you try this with

[jira] [Commented] (KAFKA-7556) KafkaConsumer.beginningOffsets does not return actual first offsets

[ https://issues.apache.org/jira/browse/KAFKA-7556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665428#comment-16665428 ] Mayuresh Gharat commented on KAFKA-7556: Hi [~rob_v], This seems like a bug to m

[jira] [Updated] (KAFKA-7556) KafkaConsumer.beginningOffsets does not return actual first offsets

[ https://issues.apache.org/jira/browse/KAFKA-7556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-7556: --- Fix Version/s: 2.2.0 > KafkaConsumer.beginningOffsets does not return actual first offsets >

[jira] [Updated] (KAFKA-7556) KafkaConsumer.beginningOffsets does not return actual first offsets

[ https://issues.apache.org/jira/browse/KAFKA-7556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-7556: --- Priority: Critical (was: Major) > KafkaConsumer.beginningOffsets does not return actual first offset

[jira] [Commented] (KAFKA-7549) Old ProduceRequest with zstd compression does not return error to client

[ https://issues.apache.org/jira/browse/KAFKA-7549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665396#comment-16665396 ] Lee Dongjin commented on KAFKA-7549: [~ijuma] I reviewed the problem. Here is the res

[jira] [Commented] (KAFKA-7385) Log cleaner crashes when empty batches are retained with idempotent or transactional producers

[ https://issues.apache.org/jira/browse/KAFKA-7385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665315#comment-16665315 ] Henning Spjelkavik commented on KAFKA-7385: We encountered this problem, but

[jira] [Commented] (KAFKA-7536) TopologyTestDriver cannot pre-populate KTable or GlobalKTable

[ https://issues.apache.org/jira/browse/KAFKA-7536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665271#comment-16665271 ] Dmitry Minkovsky commented on KAFKA-7536: - You're welcome! Thank you for Kafka an

[jira] [Updated] (KAFKA-7556) KafkaConsumer.beginningOffsets does not return actual first offsets

[ https://issues.apache.org/jira/browse/KAFKA-7556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert V updated KAFKA-7556: Description: h2. Description of the problem The method `org.apache.kafka.clients.consumer.KafkaConsumer.be

[jira] [Commented] (KAFKA-6890) Add connector level configurability for producer/consumer client configs

[ https://issues.apache.org/jira/browse/KAFKA-6890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665261#comment-16665261 ] Allen Tang commented on KAFKA-6890: --- I personally believe in exposing as much capabilit

[jira] [Created] (KAFKA-7556) KafkaConsumer.beginningOffsets does not return actual first offsets

Robert V created KAFKA-7556: --- Summary: KafkaConsumer.beginningOffsets does not return actual first offsets Key: KAFKA-7556 URL: https://issues.apache.org/jira/browse/KAFKA-7556 Project: Kafka Issu

[jira] [Updated] (KAFKA-7532) Missing stringification in error message "Removed ArrayBuffer() from list of shutting down brokers. (kafka.controller.KafkaController)"

[ https://issues.apache.org/jira/browse/KAFKA-7532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-7532: --- Fix Version/s: 2.2.0 > Missing stringification in error message "Removed ArrayBuffer() from list of

[jira] [Resolved] (KAFKA-7532) Missing stringification in error message "Removed ArrayBuffer() from list of shutting down brokers. (kafka.controller.KafkaController)"

[ https://issues.apache.org/jira/browse/KAFKA-7532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-7532. Resolution: Fixed Fix Version/s: 2.0.2 2.1.1 > Missing stringification in

[jira] [Commented] (KAFKA-7532) Missing stringification in error message "Removed ArrayBuffer() from list of shutting down brokers. (kafka.controller.KafkaController)"

[ https://issues.apache.org/jira/browse/KAFKA-7532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665194#comment-16665194 ] ASF GitHub Bot commented on KAFKA-7532: --- ijuma closed pull request #5831: KAFKA-753

[jira] [Resolved] (KAFKA-7533) Kafka consumer does not poll after commit

[ https://issues.apache.org/jira/browse/KAFKA-7533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mikhail Nemenko resolved KAFKA-7533. Resolution: Fixed > Kafka consumer does not poll after commit > ---

[jira] [Commented] (KAFKA-7547) Avoid relogin in kafka if connection is already established.

[ https://issues.apache.org/jira/browse/KAFKA-7547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665001#comment-16665001 ] Manikumar commented on KAFKA-7547: -- Since Kerberos ticket expiration times are typically

[jira] [Commented] (KAFKA-7401) Broker fails to start when recovering a segment from before the log start offset

[ https://issues.apache.org/jira/browse/KAFKA-7401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16664928#comment-16664928 ] Nand commented on KAFKA-7401: - Is there a workaround available to recover from this situation