[jira] [Commented] (KAFKA-9146) Add option to force delete members in stream reset tool

[ https://issues.apache.org/jira/browse/KAFKA-9146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006658#comment-17006658 ] feyman commented on KAFKA-9146: --- Hi, [~mjsax] I checked the code again with your guidance,

[jira] [Commented] (KAFKA-9335) java.lang.IllegalArgumentException: Number of partitions must be at least 1.

[ https://issues.apache.org/jira/browse/KAFKA-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006659#comment-17006659 ] Dongjin Lee commented on KAFKA-9335: {quote}java.lang.IllegalArgumentException: The n

[jira] [Created] (KAFKA-9354) SSL handshake failed without ssl.endpoint.identification.algorithm= and with a valid certificate

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-93

[jira] [Commented] (KAFKA-9335) java.lang.IllegalArgumentException: Number of partitions must be at least 1.

[ https://issues.apache.org/jira/browse/KAFKA-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006680#comment-17006680 ] Nitay Kufert commented on KAFKA-9335: - In the example I provided, the exception is th

[jira] [Comment Edited] (KAFKA-9335) java.lang.IllegalArgumentException: Number of partitions must be at least 1.

[ https://issues.apache.org/jira/browse/KAFKA-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006680#comment-17006680 ] Nitay Kufert edited comment on KAFKA-9335 at 1/2/20 9:13 AM: -

[jira] [Created] (KAFKA-9355) RocksDB state metrics are removed from MBeans when EOS enabled and

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 Project

[jira] [Updated] (KAFKA-9355) RocksDB metrics are removed from MBeans when EOS enabled and empty local state dir

[ 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 e

[jira] [Updated] (KAFKA-9355) RocksDB metrics are removed from MBeans when EOS enabled and empty local state dir

[ 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 sta

[jira] [Updated] (KAFKA-9355) RocksDB metrics are removed from MBeans when EOS enabled and empty local state dir

[ 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 a

[jira] [Updated] (KAFKA-9355) RocksDB metrics are removed from MBeans when EOS enabled and empty local state dir

[ 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 e

[jira] [Updated] (KAFKA-9355) RocksDB statistics are removed from MBeans when EOS enabled and empty local state dir

[ 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

[jira] [Updated] (KAFKA-9355) RocksDB statistics are removed from MBeans when EOS enabled and empty local state dir

[ 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  kafka.streams:type=stream-state-metrics

[jira] [Updated] (KAFKA-9355) RocksDB statistics are removed from MBeans when EOS enabled and empty local state dir

[ 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  kafka.streams:typ

[jira] [Updated] (KAFKA-9355) RocksDB statistics are removed from MBeans when EOS enabled and empty local state dir

[ 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 remove

[jira] [Updated] (KAFKA-9355) RocksDB statistics are removed from MBeans when EOS enabled and empty local state dir

[ 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

[jira] [Commented] (KAFKA-9353) Add groupInstanceId to DescribeGroup for better visibility

[ https://issues.apache.org/jira/browse/KAFKA-9353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006716#comment-17006716 ] ASF GitHub Bot commented on KAFKA-9353: --- dengziming commented on pull request #7886

[jira] [Updated] (KAFKA-9355) RocksDB statistics are removed from MBeans when EOS enabled and empty local state dir

[ 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 remove

[jira] [Updated] (KAFKA-9355) RocksDB statistics are removed from JMX when EOS enabled and empty local state dir

[ 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 sta

[jira] [Updated] (KAFKA-9355) RocksDB statistics are removed from JMX when EOS enabled and empty local state dir

[ 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 remove

[jira] [Commented] (KAFKA-9355) RocksDB statistics are removed from JMX when EOS enabled and empty local state dir

[ https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006722#comment-17006722 ] Stanislav Savulchik commented on KAFKA-9355: [~cadonna] could you please take

[jira] [Created] (KAFKA-9356) Potential data loss in InMemoryWindowStore and InMemorySessionStore

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

[jira] [Updated] (KAFKA-9356) Potential data loss in InMemoryWindowStore and InMemorySessionStore

[ 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 {{computeIf

[jira] [Updated] (KAFKA-9354) SSL handshake failed without ssl.endpoint.identification.algorithm= and with a valid certificate and with security.inter.broker.protocol=SSL

[ 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 val

[jira] [Updated] (KAFKA-9354) SSL handshake failed without ssl.endpoint.identification.algorithm= and with a valid certificate and with security.inter.broker.protocol=SSL

[ 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 (See

[jira] [Updated] (KAFKA-9354) SSL handshake failed without ssl.endpoint.identification.algorithm= and with a valid certificate and with security.inter.broker.protocol=SSL

[ 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 (See

[jira] [Updated] (KAFKA-9355) RocksDB statistics are removed from JMX when EOS enabled and empty local state dir

[ 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 remove

[jira] [Updated] (KAFKA-9355) RocksDB statistics are removed from JMX when EOS enabled and empty local state dir

[ 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 remove

[jira] [Created] (KAFKA-9357) Error sending fetch request

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 Compo

[jira] [Updated] (KAFKA-9357) Error sending fetch request

[ 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 th

[jira] [Updated] (KAFKA-9357) Error sending fetch request

[ 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 i

[jira] [Updated] (KAFKA-9357) Error sending fetch request

[ 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 appears

[jira] [Updated] (KAFKA-9357) Error sending fetch request

[ 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 appears

[jira] [Updated] (KAFKA-9357) Error sending fetch request

[ 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 appears

[jira] [Updated] (KAFKA-9357) Error sending fetch request

[ 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 appears

[jira] [Commented] (KAFKA-9353) Add groupInstanceId to DescribeGroup for better visibility

[ https://issues.apache.org/jira/browse/KAFKA-9353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006964#comment-17006964 ] Boyang Chen commented on KAFKA-9353: As the PR only prints the instance id, could you

[jira] [Commented] (KAFKA-9356) Potential data loss in InMemoryWindowStore and InMemorySessionStore

[ https://issues.apache.org/jira/browse/KAFKA-9356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006972#comment-17006972 ] Boyang Chen commented on KAFKA-9356: Thanks for the report. For Streams there is only

[jira] [Commented] (KAFKA-9355) RocksDB statistics are removed from JMX when EOS enabled and empty local state dir

[ https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006983#comment-17006983 ] Boyang Chen commented on KAFKA-9355: Thanks for the report. Does all RocksDB metrics

[jira] [Commented] (KAFKA-9350) IllegalStateException when materializing transactional offset commits

[ https://issues.apache.org/jira/browse/KAFKA-9350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006986#comment-17006986 ] Boyang Chen commented on KAFKA-9350: Do we have capability to trace the malicious cli

[jira] [Commented] (KAFKA-8037) KTable restore may load bad data

[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006992#comment-17006992 ] Guozhang Wang commented on KAFKA-8037: -- For non-global KTables, it now makes me thin

[jira] [Created] (KAFKA-9358) Explicitly resign controller leadership and broker znode

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

[jira] [Created] (KAFKA-9359) Controller does not handle requests while broker is being shutdown

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: Kafka

[jira] [Commented] (KAFKA-8508) saslClient failed to initialize properly: it's null.

[ https://issues.apache.org/jira/browse/KAFKA-8508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007003#comment-17007003 ] Graham Campbell commented on KAFKA-8508: This specific ArrayIndexOutOfBoundsExcep

[jira] [Assigned] (KAFKA-8037) KTable restore may load bad data

[ 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 > ---

[jira] [Commented] (KAFKA-8037) KTable restore may load bad data

[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007020#comment-17007020 ] Patrik Kleindl commented on KAFKA-8037: --- [~guozhang] I was about to ask in the thre

[jira] [Commented] (KAFKA-8037) KTable restore may load bad data

[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007062#comment-17007062 ] Sophie Blee-Goldman commented on KAFKA-8037: > Or should we just transit to n

[jira] [Commented] (KAFKA-8037) KTable restore may load bad data

[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007093#comment-17007093 ] Guozhang Wang commented on KAFKA-8037: -- [~pkleindl] for case 2) all the records befo

[jira] [Commented] (KAFKA-9350) IllegalStateException when materializing transactional offset commits

[ https://issues.apache.org/jira/browse/KAFKA-9350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007098#comment-17007098 ] Jason Gustafson commented on KAFKA-9350: [~bchen225242] I'm actually not sure wha

[jira] [Commented] (KAFKA-9335) java.lang.IllegalArgumentException: Number of partitions must be at least 1.

[ https://issues.apache.org/jira/browse/KAFKA-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007101#comment-17007101 ] Boyang Chen commented on KAFKA-9335: Thanks for the report [~nitay.k]. Could you be m

[jira] [Commented] (KAFKA-9349) Investigate new member timeout for dynamic v4 JoinGroup

[ https://issues.apache.org/jira/browse/KAFKA-9349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007105#comment-17007105 ] Guozhang Wang commented on KAFKA-9349: -- [~bchen225242] could you also take a look?

[jira] [Created] (KAFKA-9360) emitting checkpoint and heartbeat set to false will not disable the activity in their SourceTask

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

[jira] [Updated] (KAFKA-9360) emitting checkpoint and heartbeat set to false will not disable the activity in their SourceTask

[ 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

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007124#comment-17007124 ] Sophie Blee-Goldman commented on KAFKA-7994: The gist of this ticket is "Part

[jira] [Commented] (KAFKA-8522) Tombstones can survive forever

[ https://issues.apache.org/jira/browse/KAFKA-8522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007126#comment-17007126 ] ASF GitHub Bot commented on KAFKA-8522: --- ConcurrencyPractitioner commented on pull

[jira] [Commented] (KAFKA-8522) Tombstones can survive forever

[ https://issues.apache.org/jira/browse/KAFKA-8522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007127#comment-17007127 ] ASF GitHub Bot commented on KAFKA-8522: --- ConcurrencyPractitioner commented on pull

[jira] [Resolved] (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 tr

[jira] [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 reopened KAFKA-9350: > IllegalStateException when materializing transactional offset commits > -

[jira] [Updated] (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 updated KAFKA-9350: --- Fix Version/s: (was: 2.4.1) > IllegalStateException when materializing transactional offs

[jira] [Resolved] (KAFKA-8933) An unhandled SSL handshake exception in polling event - needed a retry logic

[ 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 pol

[jira] [Updated] (KAFKA-9360) emitting checkpoint and heartbeat set to false will not disable the activity in their SourceTask

[ 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

[jira] [Updated] (KAFKA-9360) emitting checkpoint and heartbeat set to false will not disable the activity in their SourceTask

[ 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 w

[jira] [Commented] (KAFKA-9360) emitting checkpoint and heartbeat set to false will not disable the activity in their SourceTask

[ https://issues.apache.org/jira/browse/KAFKA-9360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007130#comment-17007130 ] Ning Zhang commented on KAFKA-9360: --- pr link: https://github.com/apache/kafka/pull/7887

[jira] [Updated] (KAFKA-9360) emitting checkpoint and heartbeat set to false will not disable the activity in their SourceTask

[ 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

[jira] [Created] (KAFKA-9361) Consider being restrictive on overloaded commit function with specific partition->offsets

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

[jira] [Resolved] (KAFKA-8553) Kafka Connect Schema Compatibility Checks for Name Changes

[ 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, whic

[jira] [Commented] (KAFKA-6614) kafka-streams to configure internal topics message.timestamp.type=CreateTime

[ https://issues.apache.org/jira/browse/KAFKA-6614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007178#comment-17007178 ] ASF GitHub Bot commented on KAFKA-6614: --- ableegoldman commented on pull request #78

[jira] [Commented] (KAFKA-9210) kafka stream loss data

[ https://issues.apache.org/jira/browse/KAFKA-9210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007210#comment-17007210 ] panpan.liu commented on KAFKA-9210: --- I upgrade streams to 2.3.0 . And It never losses d

[jira] [Commented] (KAFKA-9355) RocksDB statistics are removed from JMX when EOS enabled and empty local state dir

[ https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007238#comment-17007238 ] Stanislav Savulchik commented on KAFKA-9355: All RocksDB metrics vanished for

[jira] [Updated] (KAFKA-9355) RocksDB statistics are removed from JMX when EOS enabled and empty local state dir

[ 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 remove

[jira] [Assigned] (KAFKA-9327) GroupMetadata metrics are not documented

[ 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 > ---

[jira] [Commented] (KAFKA-9327) GroupMetadata metrics are not documented

[ https://issues.apache.org/jira/browse/KAFKA-9327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007239#comment-17007239 ] ASF GitHub Bot commented on KAFKA-9327: --- dongjinleekr commented on pull request #78

[jira] [Commented] (KAFKA-9351) Higher count in destination cluster using Kafka MM2

[ https://issues.apache.org/jira/browse/KAFKA-9351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007241#comment-17007241 ] Nitish Goyal commented on KAFKA-9351: - Any update? > Higher count in destination clu

[jira] [Resolved] (KAFKA-9357) Error sending fetch request

[ 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 sockets