[
https://issues.apache.org/jira/browse/KAFKA-13920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleg Muravskiy updated KAFKA-13920:
---
Description:
When closing (transactional) KafkaProducer (after aborting incomplete
[
https://issues.apache.org/jira/browse/KAFKA-13920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleg Muravskiy updated KAFKA-13920:
---
Description:
{{When closing (transactional) KafkaProducer (after aborting incomplete
[
https://issues.apache.org/jira/browse/KAFKA-13920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleg Muravskiy updated KAFKA-13920:
---
Description:
{}When closing (transactional) KafkaProducer (after aborting incomplete
[
https://issues.apache.org/jira/browse/KAFKA-13920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleg Muravskiy updated KAFKA-13920:
---
Description:
{{When closing (transactional) KafkaProducer, it keeps waiting for the
[
https://issues.apache.org/jira/browse/KAFKA-13920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleg Muravskiy updated KAFKA-13920:
---
Affects Version/s: 2.8.0
(was: 2.6.2)
> KafkaProducer.close
Oleg Muravskiy created KAFKA-13920:
--
Summary: KafkaProducer.close waits idefinitely on ioThread that is
not joining
Key: KAFKA-13920
URL: https://issues.apache.org/jira/browse/KAFKA-13920
Project:
[
https://issues.apache.org/jira/browse/KAFKA-9724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084341#comment-17084341
]
Oleg Muravskiy commented on KAFKA-9724:
---
[~ijuma] Sorry – I deployed it, wanted to run for a longer
[
https://issues.apache.org/jira/browse/KAFKA-9724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071643#comment-17071643
]
Oleg Muravskiy commented on KAFKA-9724:
---
The algorithm of a consumer is fairly simple:
- subscribe
[
https://issues.apache.org/jira/browse/KAFKA-9724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071586#comment-17071586
]
Oleg Muravskiy commented on KAFKA-9724:
---
Here's the bigger fragment of a log:
[^consumer.log.xz]
[
https://issues.apache.org/jira/browse/KAFKA-9724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleg Muravskiy updated KAFKA-9724:
--
Attachment: consumer.log.xz
> Consumer wrongly ignores fetched records "since it no longer has
[
https://issues.apache.org/jira/browse/KAFKA-9724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1706#comment-1706
]
Oleg Muravskiy commented on KAFKA-9724:
---
Sure [~hachikuji]:
{noformat}
Oleg Muravskiy created KAFKA-9724:
-
Summary: Consumer wrongly ignores fetched records "since it no
longer has valid position"
Key: KAFKA-9724
URL: https://issues.apache.org/jira/browse/KAFKA-9724
Oleg Muravskiy created KAFKA-9723:
-
Summary: Consumers ignore fetched records "since it no longer has
valid position"
Key: KAFKA-9723
URL: https://issues.apache.org/jira/browse/KAFKA-9723
Project:
[
https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleg Muravskiy reopened KAFKA-9173:
---
Still an issue
> StreamsPartitionAssignor assigns partitions to only one worker
>
[
https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17001995#comment-17001995
]
Oleg Muravskiy commented on KAFKA-9173:
---
Well, we touched upon three issues here.
The very first
[
https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16988777#comment-16988777
]
Oleg Muravskiy commented on KAFKA-9173:
---
I understand that this is how it is *implemented*, but it
[
https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987696#comment-16987696
]
Oleg Muravskiy commented on KAFKA-9173:
---
[~ableegoldman] yes, I subscribe with a pattern that
[
https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987017#comment-16987017
]
Oleg Muravskiy commented on KAFKA-9173:
---
Hi [~ableegoldman],
I think I'm missing something there.
[
https://issues.apache.org/jira/browse/KAFKA-9170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16976669#comment-16976669
]
Oleg Muravskiy commented on KAFKA-9170:
---
OK, I will need some time to figure out the scope of
Oleg Muravskiy created KAFKA-9173:
-
Summary: StreamsPartitionAssignor assigns partitions to only one
worker
Key: KAFKA-9173
URL: https://issues.apache.org/jira/browse/KAFKA-9173
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-9170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16972187#comment-16972187
]
Oleg Muravskiy commented on KAFKA-9170:
---
Hi [~guozhang],
And this is exactly the problem.
if this
[
https://issues.apache.org/jira/browse/KAFKA-9170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16972187#comment-16972187
]
Oleg Muravskiy edited comment on KAFKA-9170 at 11/12/19 8:48 AM:
-
Hi
Oleg Muravskiy created KAFKA-9170:
-
Summary: KafkaStreams constructor fails to read configuration from
Properties object created with default values
Key: KAFKA-9170
URL:
Oleg Muravskiy created KAFKA-9128:
-
Summary: ConsumerCoordinator ignores exceptions from
ConsumerRebalanceListener
Key: KAFKA-9128
URL: https://issues.apache.org/jira/browse/KAFKA-9128
Project: Kafka
24 matches
Mail list logo
