[jira] [Comment Edited] (KAFKA-5875) Consumer group repeatedly fails to join, even across JVM restarts: BufferUnderFlowException reading the {{version}} field in the consumer protocol header

2020-04-12 Thread Yuriy Badalyantc (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17082026#comment-17082026 ] Yuriy Badalyantc edited comment on KAFKA-5875 at 4/13/20, 3:52 AM: --- I

[jira] [Commented] (KAFKA-5875) Consumer group repeatedly fails to join, even across JVM restarts: BufferUnderFlowException reading the {{version}} field in the consumer protocol header

2020-04-12 Thread Yuriy Badalyantc (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17082026#comment-17082026 ] Yuriy Badalyantc commented on KAFKA-5875: - I have a similar issue. I have a kafka-streams

[jira] [Commented] (KAFKA-4246) Discretionary partition assignment on the consumer side not functional

2020-04-29 Thread Yuriy Badalyantc (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096069#comment-17096069 ] Yuriy Badalyantc commented on KAFKA-4246: - This bug still exists in Kafka 2.4.0. I have 2

[jira] [Created] (KAFKA-10009) Add method for getting last record offset in kafka partition

2020-05-16 Thread Yuriy Badalyantc (Jira)
Yuriy Badalyantc created KAFKA-10009: Summary: Add method for getting last record offset in kafka partition Key: KAFKA-10009 URL: https://issues.apache.org/jira/browse/KAFKA-10009 Project: Kafka

[jira] [Updated] (KAFKA-10009) Add method for getting last record offset in kafka partition

2020-05-16 Thread Yuriy Badalyantc (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuriy Badalyantc updated KAFKA-10009: - Priority: Minor (was: Major) > Add method for getting last record offset in kafka

[jira] [Commented] (KAFKA-10009) Add method for getting last record offset in kafka partition

2020-05-16 Thread Yuriy Badalyantc (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109017#comment-17109017 ] Yuriy Badalyantc commented on KAFKA-10009: -- Even with read_committed isolation level

[jira] [Commented] (KAFKA-10009) Add method for getting last record offset in kafka partition

2020-05-16 Thread Yuriy Badalyantc (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109054#comment-17109054 ] Yuriy Badalyantc commented on KAFKA-10009: -- Exactly. I want an offset of a last true record in

[jira] [Updated] (KAFKA-10020) KIP-616: Rename implicit Serdes instances in kafka-streams-scala

2020-05-18 Thread Yuriy Badalyantc (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuriy Badalyantc updated KAFKA-10020: - Component/s: streams Affects Version/s: 2.5.0 Priority: Minor

[jira] [Created] (KAFKA-10020) KIP-616: Rename implicit Serdes instances in kafka-streams-scala

2020-05-18 Thread Yuriy Badalyantc (Jira)
Yuriy Badalyantc created KAFKA-10020: Summary: KIP-616: Rename implicit Serdes instances in kafka-streams-scala Key: KAFKA-10020 URL: https://issues.apache.org/jira/browse/KAFKA-10020 Project:

[jira] [Created] (KAFKA-10576) Different behavior of commitSync and commitAsync

2020-10-05 Thread Yuriy Badalyantc (Jira)
Yuriy Badalyantc created KAFKA-10576: Summary: Different behavior of commitSync and commitAsync Key: KAFKA-10576 URL: https://issues.apache.org/jira/browse/KAFKA-10576 Project: Kafka

[jira] [Updated] (KAFKA-10576) Different behavior of commitSync and commitAsync

2020-10-05 Thread Yuriy Badalyantc (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuriy Badalyantc updated KAFKA-10576: - Description: It looks like {{commitSync}} and {{commitAsync}} consumer's methods have a