[
https://issues.apache.org/jira/browse/KAFKA-9357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongjin Lee resolved KAFKA-9357.
Resolution: Not A Problem
Could you check the resource status in node 2? (For example, open
[
https://issues.apache.org/jira/browse/KAFKA-9351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007241#comment-17007241
]
Nitish Goyal commented on KAFKA-9351:
-
Any update?
> Higher count in destination cluster using Kafka
[
https://issues.apache.org/jira/browse/KAFKA-9327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007239#comment-17007239
]
ASF GitHub Bot commented on KAFKA-9327:
---
dongjinleekr commented on pull request #7890: KAFKA-9327:
[
https://issues.apache.org/jira/browse/KAFKA-9327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongjin Lee reassigned KAFKA-9327:
--
Assignee: Dongjin Lee
> GroupMetadata metrics are not documented
>
[
https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Savulchik updated KAFKA-9355:
---
Description:
*Steps to Reproduce*
Set processing.guarantee = exactly_once and
[
https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007238#comment-17007238
]
Stanislav Savulchik commented on KAFKA-9355:
All RocksDB metrics vanished for all restoring
[
https://issues.apache.org/jira/browse/KAFKA-9210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007210#comment-17007210
]
panpan.liu commented on KAFKA-9210:
---
I upgrade streams to 2.3.0 . And It never losses data.
> kafka
[
https://issues.apache.org/jira/browse/KAFKA-6614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007178#comment-17007178
]
ASF GitHub Bot commented on KAFKA-6614:
---
ableegoldman commented on pull request #7889: KAFKA-6614:
[
https://issues.apache.org/jira/browse/KAFKA-8553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongjin Lee resolved KAFKA-8553.
Resolution: Not A Problem
In Kafka Connect, there are two kinds of 'schema's:
1. Avro schema,
Guozhang Wang created KAFKA-9361:
Summary: Consider being restrictive on overloaded commit function
with specific partition->offsets
Key: KAFKA-9361
URL: https://issues.apache.org/jira/browse/KAFKA-9361
[
https://issues.apache.org/jira/browse/KAFKA-9360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007130#comment-17007130
]
Ning Zhang commented on KAFKA-9360:
---
pr link: https://github.com/apache/kafka/pull/7887
> emitting
[
https://issues.apache.org/jira/browse/KAFKA-9360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ning Zhang updated KAFKA-9360:
--
Description:
`emit.heartbeats.enabled` and `emit.checkpoints.enabled` are supposed to be the
knobs to
[
https://issues.apache.org/jira/browse/KAFKA-9350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-9350:
---
Fix Version/s: (was: 2.4.1)
> IllegalStateException when materializing transactional
[
https://issues.apache.org/jira/browse/KAFKA-8933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-8933.
Fix Version/s: 2.4.1
Resolution: Fixed
> An unhandled SSL handshake exception in
[
https://issues.apache.org/jira/browse/KAFKA-9360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ning Zhang updated KAFKA-9360:
--
Description:
`emit.heartbeats.enabled` and `emit.checkpoints.enabled` are supposed to be the
knobs to
[
https://issues.apache.org/jira/browse/KAFKA-9360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ning Zhang updated KAFKA-9360:
--
Attachment: Screen Shot 2020-01-02 at 3.18.23 PM.png
> emitting checkpoint and heartbeat set to false
[
https://issues.apache.org/jira/browse/KAFKA-9350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson reopened KAFKA-9350:
> IllegalStateException when materializing transactional offset commits
>
[
https://issues.apache.org/jira/browse/KAFKA-9350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-9350.
Fix Version/s: 2.4.1
Resolution: Fixed
> IllegalStateException when materializing
[
https://issues.apache.org/jira/browse/KAFKA-8522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007127#comment-17007127
]
ASF GitHub Bot commented on KAFKA-8522:
---
ConcurrencyPractitioner commented on pull request #7884:
[
https://issues.apache.org/jira/browse/KAFKA-8522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007126#comment-17007126
]
ASF GitHub Bot commented on KAFKA-8522:
---
ConcurrencyPractitioner commented on pull request #7884:
[
https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007124#comment-17007124
]
Sophie Blee-Goldman commented on KAFKA-7994:
The gist of this ticket is "Partition-time, the
[
https://issues.apache.org/jira/browse/KAFKA-9360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ning Zhang updated KAFKA-9360:
--
Description:
`emit.heartbeats.enabled` and `emit.checkpoints.enabled` are supposed to be the
knobs to
Ning Zhang created KAFKA-9360:
-
Summary: emitting checkpoint and heartbeat set to false will not
disable the activity in their SourceTask
Key: KAFKA-9360
URL: https://issues.apache.org/jira/browse/KAFKA-9360
[
https://issues.apache.org/jira/browse/KAFKA-9349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007105#comment-17007105
]
Guozhang Wang commented on KAFKA-9349:
--
[~bchen225242] could you also take a look?
> Investigate
[
https://issues.apache.org/jira/browse/KAFKA-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007101#comment-17007101
]
Boyang Chen commented on KAFKA-9335:
Thanks for the report [~nitay.k]. Could you be more specific
[
https://issues.apache.org/jira/browse/KAFKA-9350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007098#comment-17007098
]
Jason Gustafson commented on KAFKA-9350:
[~bchen225242] I'm actually not sure what happened here.
[
https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007093#comment-17007093
]
Guozhang Wang commented on KAFKA-8037:
--
[~pkleindl] for case 2) all the records before the committed
[
https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007062#comment-17007062
]
Sophie Blee-Goldman commented on KAFKA-8037:
> Or should we just transit to normal processing
[
https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Patrik Kleindl reassigned KAFKA-8037:
-
Assignee: (was: Patrik Kleindl)
> KTable restore may load bad data
>
[
https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007020#comment-17007020
]
Patrik Kleindl commented on KAFKA-8037:
---
[~guozhang] I was about to ask in the thread of KAFKA-7663
[
https://issues.apache.org/jira/browse/KAFKA-8508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007003#comment-17007003
]
Graham Campbell commented on KAFKA-8508:
This specific ArrayIndexOutOfBoundsException is actually
Lucas Bradstreet created KAFKA-9359:
---
Summary: Controller does not handle requests while broker is being
shutdown
Key: KAFKA-9359
URL: https://issues.apache.org/jira/browse/KAFKA-9359
Project:
Lucas Bradstreet created KAFKA-9358:
---
Summary: Explicitly resign controller leadership and broker znode
Key: KAFKA-9358
URL: https://issues.apache.org/jira/browse/KAFKA-9358
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006992#comment-17006992
]
Guozhang Wang commented on KAFKA-8037:
--
For non-global KTables, it now makes me thinking if our
[
https://issues.apache.org/jira/browse/KAFKA-9350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006986#comment-17006986
]
Boyang Chen commented on KAFKA-9350:
Do we have capability to trace the malicious client in this
[
https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006983#comment-17006983
]
Boyang Chen commented on KAFKA-9355:
Thanks for the report. Does all RocksDB metrics vanish or some
[
https://issues.apache.org/jira/browse/KAFKA-9356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006972#comment-17006972
]
Boyang Chen commented on KAFKA-9356:
Thanks for the report. For Streams there is only one writer
[
https://issues.apache.org/jira/browse/KAFKA-9353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006964#comment-17006964
]
Boyang Chen commented on KAFKA-9353:
As the PR only prints the instance id, could you rename the
[
https://issues.apache.org/jira/browse/KAFKA-9357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Byoung joo, Lee updated KAFKA-9357:
---
Description:
It was 'OK' at first.
I haven't had it for more than six months, but it
[
https://issues.apache.org/jira/browse/KAFKA-9357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Byoung joo, Lee updated KAFKA-9357:
---
Description:
It was 'OK' at first.
I haven't had it for more than six months, but it
[
https://issues.apache.org/jira/browse/KAFKA-9357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Byoung joo, Lee updated KAFKA-9357:
---
Description:
It was 'OK' at first.
I haven't had it for more than six months, but it
[
https://issues.apache.org/jira/browse/KAFKA-9357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Byoung joo, Lee updated KAFKA-9357:
---
Description:
It was 'OK' at first.
I haven't had it for more than six months, but it
[
https://issues.apache.org/jira/browse/KAFKA-9357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Byoung joo, Lee updated KAFKA-9357:
---
Description:
It was 'OK' at first.
I haven't had it for more than six months, but suddenly
[
https://issues.apache.org/jira/browse/KAFKA-9357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Byoung joo, Lee updated KAFKA-9357:
---
Description:
It was 'OK' at first, but restarting after the first occurrence also reduced
Byoung joo, Lee created KAFKA-9357:
--
Summary: Error sending fetch request
Key: KAFKA-9357
URL: https://issues.apache.org/jira/browse/KAFKA-9357
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Savulchik updated KAFKA-9355:
---
Description:
*Steps to Reproduce*
Set processing.guarantee = exactly_once and
[
https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Savulchik updated KAFKA-9355:
---
Description:
*Steps to Reproduce*
Set processing.guarantee = exactly_once and
[
https://issues.apache.org/jira/browse/KAFKA-9354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Agostino Sarubbo updated KAFKA-9354:
Description:
I tried to make an SSL setup but the documentation looks to be incomplete
[
https://issues.apache.org/jira/browse/KAFKA-9354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Agostino Sarubbo updated KAFKA-9354:
Description:
I tried to make an SSL setup but the documentation looks to be incomplete
[
https://issues.apache.org/jira/browse/KAFKA-9354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Agostino Sarubbo updated KAFKA-9354:
Summary: SSL handshake failed without
ssl.endpoint.identification.algorithm= and with a
Roman Leventov created KAFKA-9356:
-
Summary: Potential data loss in InMemoryWindowStore and
InMemorySessionStore
Key: KAFKA-9356
URL: https://issues.apache.org/jira/browse/KAFKA-9356
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-9356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Leventov updated KAFKA-9356:
--
Description:
{{InMemoryWindowStore.put()}} and {{InMemorySessionStore.put()}} call
[
https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006722#comment-17006722
]
Stanislav Savulchik commented on KAFKA-9355:
[~cadonna] could you please take a look at this
[
https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Savulchik updated KAFKA-9355:
---
Description:
*Steps to Reproduce*
Set processing.guarantee = exactly_once and
[
https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Savulchik updated KAFKA-9355:
---
Summary: RocksDB statistics are removed from JMX when EOS enabled and empty
local
[
https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Savulchik updated KAFKA-9355:
---
Description:
*Steps to Reproduce*
Set processing.guarantee = exactly_once and
[
https://issues.apache.org/jira/browse/KAFKA-9353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006716#comment-17006716
]
ASF GitHub Bot commented on KAFKA-9353:
---
dengziming commented on pull request #7886: KAFKA-9353:
[
https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Savulchik updated KAFKA-9355:
---
Attachment: metric-removal.log
> RocksDB statistics are removed from MBeans when EOS
[
https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Savulchik updated KAFKA-9355:
---
Description:
*Steps to Reproduce*
Set processing.guarantee = exactly_once and
[
https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Savulchik updated KAFKA-9355:
---
Description:
*Expected Behavior*
There are registered MBeans like
[
https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Savulchik updated KAFKA-9355:
---
Description:
*Expected behavior*
There are
[
https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Savulchik updated KAFKA-9355:
---
Summary: RocksDB statistics are removed from MBeans when EOS enabled and
empty local
[
https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Savulchik updated KAFKA-9355:
---
Component/s: metrics
> RocksDB metrics are removed from MBeans when EOS enabled and
[
https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Savulchik updated KAFKA-9355:
---
Component/s: streams
> RocksDB metrics are removed from MBeans when EOS enabled and
[
https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Savulchik updated KAFKA-9355:
---
Summary: RocksDB metrics are removed from MBeans when EOS enabled and empty
local
[
https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Savulchik updated KAFKA-9355:
---
Affects Version/s: 2.4.0
> RocksDB metrics are removed from MBeans when EOS enabled
Stanislav Savulchik created KAFKA-9355:
--
Summary: RocksDB state metrics are removed from MBeans when EOS
enabled and
Key: KAFKA-9355
URL: https://issues.apache.org/jira/browse/KAFKA-9355
[
https://issues.apache.org/jira/browse/KAFKA-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006680#comment-17006680
]
Nitay Kufert edited comment on KAFKA-9335 at 1/2/20 9:13 AM:
-
In the example
[
https://issues.apache.org/jira/browse/KAFKA-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006680#comment-17006680
]
Nitay Kufert commented on KAFKA-9335:
-
In the example I provided, the exception is thrown over the
Agostino Sarubbo created KAFKA-9354:
---
Summary: SSL handshake failed without
ssl.endpoint.identification.algorithm= and with a valid certificate
Key: KAFKA-9354
URL:
[
https://issues.apache.org/jira/browse/KAFKA-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006659#comment-17006659
]
Dongjin Lee commented on KAFKA-9335:
{quote}java.lang.IllegalArgumentException: The number of
[
https://issues.apache.org/jira/browse/KAFKA-9146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006658#comment-17006658
]
feyman commented on KAFKA-9146:
---
Hi, [~mjsax]
I checked the code again with your guidance, per your
72 matches
Mail list logo