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
[
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|https://github.com/apache/kafka/blob/trunk/connect/runtime/src
[
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|https://github.com/apache/kafka/blob/trunk/connect/runtime/src
[
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, rat
[
https://issues.apache.org/jira/browse/KAFKA-10009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173671#comment-17173671
]
Werner Daehn commented on KAFKA-10009:
--
What would be needed is either
* endOffset
[
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
> -
[
https://issues.apache.org/jira/browse/KAFKA-10009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173661#comment-17173661
]
Werner Daehn commented on KAFKA-10009:
--
It is actually worse than that.
There coul
[
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 stuck
[
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
[
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 fail
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
[
https://issues.apache.org/jira/browse/KAFKA-9659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173636#comment-17173636
]
Levani Kokhreidze commented on KAFKA-9659:
--
Hi [~guozhang] just wanted to let yo
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 messa
[
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 /tmp/kafka-logs/cleaner-offset-
[
https://issues.apache.org/jira/browse/KAFKA-10352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173595#comment-17173595
]
Seongbae Chang commented on KAFKA-10352:
Thank you for your answer, [~dongjin]!
15 matches
Mail list logo