[jira] [Created] (KAFKA-10376) TimeWindowedDeserializer does not deserialize the end timestamp of time window aggregate message keys.

B R created KAFKA-10376: --- Summary: TimeWindowedDeserializer does not deserialize the end timestamp of time window aggregate message keys. Key: KAFKA-10376 URL: https://issues.apache.org/jira/browse/KAFKA-10376

[jira] [Updated] (KAFKA-10370) WorkerSinkTask: IllegalStateException cased by consumer.seek(tp, offsets) when (tp, offsets) are supplied by WorkerSinkTaskContext

[ https://issues.apache.org/jira/browse/KAFKA-10370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ning Zhang updated KAFKA-10370: --- Description: In

[jira] [Updated] (KAFKA-10370) WorkerSinkTask: IllegalStateException cased by consumer.seek(tp, offsets) when (tp, offsets) are supplied by WorkerSinkTaskContext

[ https://issues.apache.org/jira/browse/KAFKA-10370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ning Zhang updated KAFKA-10370: --- Description: In

[jira] [Updated] (KAFKA-10370) WorkerSinkTask: IllegalStateException cased by consumer.seek(tp, offsets) when (tp, offsets) are supplied by WorkerSinkTaskContext

[ https://issues.apache.org/jira/browse/KAFKA-10370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ning Zhang updated KAFKA-10370: --- Description: In WorkerSinkTask.java, when we want the consumer to consume from certain offsets,

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

[ https://issues.apache.org/jira/browse/KAFKA-10009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17173671#comment-17173671 ] Werner Daehn commented on KAFKA-10009: -- What would be needed is either * endOffsets() returns the

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-10009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17173661#comment-17173661 ] Werner Daehn commented on KAFKA-10009: -- It is actually worse than that. There could be log

[jira] [Updated] (KAFKA-10373) Kafka Reassign Partition is stuck with Java OutOfMemory error

[ https://issues.apache.org/jira/browse/KAFKA-10373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-10373: -- Component/s: (was: KafkaConnect) core > Kafka Reassign Partition is

[jira] [Updated] (KAFKA-10375) Restore consumer fails with SSL handshake fail exception

[ https://issues.apache.org/jira/browse/KAFKA-10375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze updated KAFKA-10375: -- Attachment: stacktrace.txt > Restore consumer fails with SSL handshake fail exception

[jira] [Updated] (KAFKA-10375) Restore consumer fails with SSL handshake fail exception

[ https://issues.apache.org/jira/browse/KAFKA-10375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze updated KAFKA-10375: -- Attachment: (was: stacktrace.txt) > Restore consumer fails with SSL handshake

[jira] [Created] (KAFKA-10375) Restore consumer fails with SSL handshake fail exception

Levani Kokhreidze created KAFKA-10375: - Summary: Restore consumer fails with SSL handshake fail exception Key: KAFKA-10375 URL: https://issues.apache.org/jira/browse/KAFKA-10375 Project: Kafka

[jira] [Commented] (KAFKA-9659) Kafka Streams / Consumer configured for static membership fails on "fatal exception: group.instance.id gets fenced"

[ https://issues.apache.org/jira/browse/KAFKA-9659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17173636#comment-17173636 ] Levani Kokhreidze commented on KAFKA-9659: -- Hi [~guozhang] just wanted to let you know that

[GitHub] [kafka] jeqo commented on pull request #9137: KAFKA-9929: Support reverse iterator on KeyValueStore

jeqo commented on pull request #9137: URL: https://github.com/apache/kafka/pull/9137#issuecomment-670850075 cc @ableegoldman This PR is ready for review, covering related feedback from #8976 This is an automated

[jira] [Resolved] (KAFKA-10352) Error while reading checkpoint file /tmp/kafka-logs/cleaner-offset-checkpoint (kafka.server.LogDirFailureChannel)

[ https://issues.apache.org/jira/browse/KAFKA-10352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seongbae Chang resolved KAFKA-10352. Resolution: Resolved > Error while reading checkpoint file

[jira] [Commented] (KAFKA-10352) Error while reading checkpoint file /tmp/kafka-logs/cleaner-offset-checkpoint (kafka.server.LogDirFailureChannel)

[ https://issues.apache.org/jira/browse/KAFKA-10352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17173595#comment-17173595 ] Seongbae Chang commented on KAFKA-10352: Thank you for your answer, [~dongjin]! According to

[GitHub] [kafka] ning2008wisc removed a comment on pull request #9145: KAFKA-10370: rewind consumer to SinkTaskContext's offsets when init

ning2008wisc removed a comment on pull request #9145: URL: https://github.com/apache/kafka/pull/9145#issuecomment-670820575 As mentioned in https://stackoverflow.com/questions/54480715/no-current-assignment-for-partition-occurs-even-after-poll-in-kafka, another potential resolution could