[jira] [Resolved] (KAFKA-9150) DescribeGroup uses member assignment as metadata

[ https://issues.apache.org/jira/browse/KAFKA-9150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-9150. -- Resolution: Fixed > DescribeGroup uses member assignment as metadata >

[jira] [Commented] (KAFKA-9044) Brokers occasionally (randomly?) dropping out of clusters

[ https://issues.apache.org/jira/browse/KAFKA-9044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968926#comment-16968926 ] Jun Rao commented on KAFKA-9044: When a broker establishes a ZK session, it should log th

[jira] [Commented] (KAFKA-9150) DescribeGroup uses member assignment as metadata

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

[jira] [Commented] (KAFKA-9044) Brokers occasionally (randomly?) dropping out of clusters

[ https://issues.apache.org/jira/browse/KAFKA-9044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968899#comment-16968899 ] Peter Bukowinski commented on KAFKA-9044: - I’m not sure how to go about checking

[jira] [Commented] (KAFKA-9044) Brokers occasionally (randomly?) dropping out of clusters

[ https://issues.apache.org/jira/browse/KAFKA-9044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968861#comment-16968861 ] Jun Rao commented on KAFKA-9044: Hmm, I did a quick check and the controller seems to nev

[jira] [Commented] (KAFKA-9044) Brokers occasionally (randomly?) dropping out of clusters

[ https://issues.apache.org/jira/browse/KAFKA-9044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968845#comment-16968845 ] Peter Bukowinski commented on KAFKA-9044: - I'm pretty sure this session was creat

[jira] [Commented] (KAFKA-9044) Brokers occasionally (randomly?) dropping out of clusters

[ https://issues.apache.org/jira/browse/KAFKA-9044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968833#comment-16968833 ] Jun Rao commented on KAFKA-9044: Interesting, that ZK session lasted for only 30 secs. Th

[jira] [Commented] (KAFKA-9044) Brokers occasionally (randomly?) dropping out of clusters

[ https://issues.apache.org/jira/browse/KAFKA-9044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968804#comment-16968804 ] Peter Bukowinski commented on KAFKA-9044: - What would such an entry look like? Th

[jira] [Commented] (KAFKA-9148) Consider forking RocksDB for Streams

[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968797#comment-16968797 ] Boyang Chen commented on KAFKA-9148: If we gave user the option to use either fRocksD

[jira] [Commented] (KAFKA-9044) Brokers occasionally (randomly?) dropping out of clusters

[ https://issues.apache.org/jira/browse/KAFKA-9044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968793#comment-16968793 ] Jun Rao commented on KAFKA-9044: Did the ZK log show that broker 23's ZK session expired

[jira] [Commented] (KAFKA-9148) Consider forking RocksDB for Streams

[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968777#comment-16968777 ] Sophie Blee-Goldman commented on KAFKA-9148: It seems to also be under the Ap

[jira] [Commented] (KAFKA-9148) Consider forking RocksDB for Streams

[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968772#comment-16968772 ] Sophie Blee-Goldman commented on KAFKA-9148: That's an interesting idea...and

[jira] [Assigned] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-7895: --- Assignee: John Roesler (was: Guozhang Wang) > Ktable supress operator emitting more than on

[jira] [Assigned] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-7895: --- Assignee: Guozhang Wang (was: John Roesler) > Ktable supress operator emitting more than on

[jira] [Commented] (KAFKA-8729) Augment ProduceResponse error messaging for specific culprit records

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

[jira] [Comment Edited] (KAFKA-6947) Mirrormaker Closing producer due to send failure

[ https://issues.apache.org/jira/browse/KAFKA-6947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968664#comment-16968664 ] artem edited comment on KAFKA-6947 at 11/6/19 8:16 PM: --- Face the sa

[jira] [Commented] (KAFKA-6947) Mirrormaker Closing producer due to send failure

[ https://issues.apache.org/jira/browse/KAFKA-6947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968664#comment-16968664 ] artem commented on KAFKA-6947: -- Face the same error (0.11.0) {code:java} [2019-11-06 14:03

[jira] [Updated] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8803: - Component/s: streams > Stream will not start due to TimeoutException: Timeout expired after > 60

[jira] [Commented] (KAFKA-9133) LogCleaner thread dies with: currentLog cannot be empty on an unexpected exception

[ https://issues.apache.org/jira/browse/KAFKA-9133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968639#comment-16968639 ] Karolis Pocius commented on KAFKA-9133: --- Thank you for the update. Will be happy to

[jira] [Commented] (KAFKA-9144) Early expiration of producer state can cause coordinator epoch to regress

[ https://issues.apache.org/jira/browse/KAFKA-9144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968636#comment-16968636 ] Guozhang Wang commented on KAFKA-9144: -- Looked through the code and I agree we shoul

[jira] [Comment Edited] (KAFKA-9044) Brokers occasionally (randomly?) dropping out of clusters

[ https://issues.apache.org/jira/browse/KAFKA-9044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968622#comment-16968622 ] Peter Bukowinski edited comment on KAFKA-9044 at 11/6/19 7:11 PM: -

[jira] [Commented] (KAFKA-9044) Brokers occasionally (randomly?) dropping out of clusters

[ https://issues.apache.org/jira/browse/KAFKA-9044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968622#comment-16968622 ] Peter Bukowinski commented on KAFKA-9044: - I parsed the zk transaction log and th

[jira] [Assigned] (KAFKA-2499) kafka-producer-perf-test should use something more realistic than empty byte arrays

[ https://issues.apache.org/jira/browse/KAFKA-2499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edward Ribeiro reassigned KAFKA-2499: - Assignee: (was: Edward Ribeiro) > kafka-producer-perf-test should use something more

[jira] [Comment Edited] (KAFKA-9044) Brokers occasionally (randomly?) dropping out of clusters

[ https://issues.apache.org/jira/browse/KAFKA-9044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968593#comment-16968593 ] Peter Bukowinski edited comment on KAFKA-9044 at 11/6/19 6:45 PM: -

[jira] [Comment Edited] (KAFKA-9044) Brokers occasionally (randomly?) dropping out of clusters

[ https://issues.apache.org/jira/browse/KAFKA-9044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968593#comment-16968593 ] Peter Bukowinski edited comment on KAFKA-9044 at 11/6/19 6:41 PM: -

[jira] [Commented] (KAFKA-9044) Brokers occasionally (randomly?) dropping out of clusters

[ https://issues.apache.org/jira/browse/KAFKA-9044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968593#comment-16968593 ] Peter Bukowinski commented on KAFKA-9044: - I had another drop-out today. Here is

[jira] [Updated] (KAFKA-9133) LogCleaner thread dies with: currentLog cannot be empty on an unexpected exception

[ https://issues.apache.org/jira/browse/KAFKA-9133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-9133: --- Fix Version/s: 2.3.2 2.4.0 > LogCleaner thread dies with: currentLog canno

[jira] [Assigned] (KAFKA-9133) LogCleaner thread dies with: currentLog cannot be empty on an unexpected exception

[ https://issues.apache.org/jira/browse/KAFKA-9133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-9133: -- Assignee: Jason Gustafson > LogCleaner thread dies with: currentLog cannot be empty on

[jira] [Updated] (KAFKA-9133) LogCleaner thread dies with: currentLog cannot be empty on an unexpected exception

[ https://issues.apache.org/jira/browse/KAFKA-9133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-9133: --- Priority: Blocker (was: Major) > LogCleaner thread dies with: currentLog cannot be empty on

[jira] [Commented] (KAFKA-9133) LogCleaner thread dies with: currentLog cannot be empty on an unexpected exception

[ https://issues.apache.org/jira/browse/KAFKA-9133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968589#comment-16968589 ] Jason Gustafson commented on KAFKA-9133: [~Karolis] Thanks for filing the issue.

[jira] [Resolved] (KAFKA-9140) Consumer gets stuck rejoining the group indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-9140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-9140. -- Assignee: Guozhang Wang Resolution: Fixed > Consumer gets stuck rejoining the group indefinitely

[jira] [Commented] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968567#comment-16968567 ] Gwen Shapira commented on KAFKA-8677: - https://builds.apache.org/job/kafka-pr-jdk8-sc

[jira] [Commented] (KAFKA-9140) Consumer gets stuck rejoining the group indefinitely

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

[jira] [Commented] (KAFKA-9044) Brokers occasionally (randomly?) dropping out of clusters

[ https://issues.apache.org/jira/browse/KAFKA-9044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968545#comment-16968545 ] Jun Rao commented on KAFKA-9044: It may also be useful to parse the ZK commit log to see

[jira] [Commented] (KAFKA-9148) Consider forking RocksDB for Streams

[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968534#comment-16968534 ] John Roesler commented on KAFKA-9148: - Thanks for the additional detail. I had one o

[jira] [Commented] (KAFKA-9150) DescribeGroup uses member assignment as metadata

[ https://issues.apache.org/jira/browse/KAFKA-9150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968519#comment-16968519 ] ASF GitHub Bot commented on KAFKA-9150: --- dajac commented on pull request #7658: KAF

[jira] [Assigned] (KAFKA-9124) ISR changes should be propagated via Kafka protocol

[ https://issues.apache.org/jira/browse/KAFKA-9124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana reassigned KAFKA-9124: - Assignee: Satish Duggana > ISR changes should be propagated via Kafka protocol > ---

[jira] [Commented] (KAFKA-9125) GroupMetadataManager and TransactionStateManager should use metadata cache instead of zkClient

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

[jira] [Updated] (KAFKA-9153) Kafka brokers randomly crash (SIGSEGV due to kafka errors)

[ https://issues.apache.org/jira/browse/KAFKA-9153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tristan updated KAFKA-9153: --- Description: We upgraded our kafka brokers on many clusters to 2.1.1 a few month ago and did not encountered

[jira] [Updated] (KAFKA-9153) Kafka brokers randomly crash (SIGSEGV due to kafka errors)

[ https://issues.apache.org/jira/browse/KAFKA-9153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tristan updated KAFKA-9153: --- Description: We upgraded our kafka brokers on many clusters to 2.1.1 a few month ago and did not encountered

[jira] [Updated] (KAFKA-9153) Kafka brokers randomly crash (SIGSEGV due to kafka errors)

[ https://issues.apache.org/jira/browse/KAFKA-9153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tristan updated KAFKA-9153: --- Description: We upgraded our kafka brokers on many clusters to 2.1.1 a few month ago and did not encountered

[jira] [Created] (KAFKA-9154) ProducerId generation should be managed by the Controller

Viktor Somogyi-Vass created KAFKA-9154: -- Summary: ProducerId generation should be managed by the Controller Key: KAFKA-9154 URL: https://issues.apache.org/jira/browse/KAFKA-9154 Project: Kafka

[jira] [Created] (KAFKA-9153) Kafka brokers randomly crash (SIGSEGV due to kafka errors)

Tristan created KAFKA-9153: -- Summary: Kafka brokers randomly crash (SIGSEGV due to kafka errors) Key: KAFKA-9153 URL: https://issues.apache.org/jira/browse/KAFKA-9153 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-9125) GroupMetadataManager and TransactionStateManager should use metadata cache instead of zkClient

[ https://issues.apache.org/jira/browse/KAFKA-9125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968349#comment-16968349 ] Ismael Juma commented on KAFKA-9125: The cache is asynchronously updated and there's

[jira] [Assigned] (KAFKA-9125) GroupMetadataManager and TransactionStateManager should use metadata cache instead of zkClient

[ https://issues.apache.org/jira/browse/KAFKA-9125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi-Vass reassigned KAFKA-9125: -- Assignee: Viktor Somogyi-Vass > GroupMetadataManager and TransactionStateManag

[jira] [Commented] (KAFKA-9147) zookeeper service not running

[ https://issues.apache.org/jira/browse/KAFKA-9147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968322#comment-16968322 ] Mickael Maison commented on KAFKA-9147: --- It looks like you want to open an issue ag

[jira] [Commented] (KAFKA-9150) DescribeGroup uses member assignment as metadata

[ https://issues.apache.org/jira/browse/KAFKA-9150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968295#comment-16968295 ] Ismael Juma commented on KAFKA-9150: [~huxi_2b], it's OK if you submitted the PR at m

[jira] [Commented] (KAFKA-9044) Brokers occasionally (randomly?) dropping out of clusters

[ https://issues.apache.org/jira/browse/KAFKA-9044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968291#comment-16968291 ] Ismael Juma commented on KAFKA-9044: If you can share, it would be useful to have acc

[jira] [Commented] (KAFKA-9044) Brokers occasionally (randomly?) dropping out of clusters

[ https://issues.apache.org/jira/browse/KAFKA-9044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968290#comment-16968290 ] Ismael Juma commented on KAFKA-9044: Is the broker still connected to zk? That is, do

[jira] [Commented] (KAFKA-9142) topic __transaction_state disk space grows too big

[ https://issues.apache.org/jira/browse/KAFKA-9142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968285#comment-16968285 ] panpan.liu commented on KAFKA-9142: --- [~guozhang]  [~boquan]        could please see the

[jira] [Assigned] (KAFKA-9079) System Test Failure: TransactionsTest

[ https://issues.apache.org/jira/browse/KAFKA-9079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-9079: Assignee: Jason Gustafson (was: Manikumar) > System Test Failure: TransactionsTest >

[jira] [Resolved] (KAFKA-9079) System Test Failure: TransactionsTest

[ https://issues.apache.org/jira/browse/KAFKA-9079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-9079. -- Fix Version/s: (was: 2.5.0) 2.4.0 Resolution: Fixed Issue resolved by pul

[jira] [Assigned] (KAFKA-9079) System Test Failure: TransactionsTest

[ https://issues.apache.org/jira/browse/KAFKA-9079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-9079: Assignee: Manikumar > System Test Failure: TransactionsTest >

[jira] [Commented] (KAFKA-9079) System Test Failure: TransactionsTest

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

[jira] [Updated] (KAFKA-9152) Improve Sensor Retrieval

[ https://issues.apache.org/jira/browse/KAFKA-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-9152: - Priority: Minor (was: Major) > Improve Sensor Retrieval > - > >

[jira] [Updated] (KAFKA-9152) Improve Sensor Retrieval

[ https://issues.apache.org/jira/browse/KAFKA-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-9152: - Labels: newbie tech-debt (was: tech-debt) > Improve Sensor Retrieval >

[jira] [Created] (KAFKA-9152) Improve Sensor Retrieval

Bruno Cadonna created KAFKA-9152: Summary: Improve Sensor Retrieval Key: KAFKA-9152 URL: https://issues.apache.org/jira/browse/KAFKA-9152 Project: Kafka Issue Type: Improvement Com

[jira] [Commented] (KAFKA-9150) DescribeGroup uses member assignment as metadata

[ https://issues.apache.org/jira/browse/KAFKA-9150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968211#comment-16968211 ] huxihx commented on KAFKA-9150: --- Do not be aware that  David Jacot already takes the jira.

[jira] [Commented] (KAFKA-9150) DescribeGroup uses member assignment as metadata

[ https://issues.apache.org/jira/browse/KAFKA-9150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968208#comment-16968208 ] ASF GitHub Bot commented on KAFKA-9150: --- huxihx commented on pull request #7655: KA

[jira] [Commented] (KAFKA-9150) DescribeGroup uses member assignment as metadata

[ https://issues.apache.org/jira/browse/KAFKA-9150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968206#comment-16968206 ] ASF GitHub Bot commented on KAFKA-9150: --- huxihx commented on pull request #7655: KA

[jira] [Commented] (KAFKA-9149) Avoid temp byte array creation when use ByteBufferSerializer

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

[jira] [Created] (KAFKA-9151) KafkaProducer.send should warmup metadata information when application starts

Tao Chen created KAFKA-9151: --- Summary: KafkaProducer.send should warmup metadata information when application starts Key: KAFKA-9151 URL: https://issues.apache.org/jira/browse/KAFKA-9151 Project: Kafka

[jira] [Assigned] (KAFKA-9150) DescribeGroup uses member assignment as metadata

[ https://issues.apache.org/jira/browse/KAFKA-9150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot reassigned KAFKA-9150: -- Assignee: David Jacot > DescribeGroup uses member assignment as metadata > ---

[jira] [Created] (KAFKA-9150) DescribeGroup uses member assignment as metadata

Jason Gustafson created KAFKA-9150: -- Summary: DescribeGroup uses member assignment as metadata Key: KAFKA-9150 URL: https://issues.apache.org/jira/browse/KAFKA-9150 Project: Kafka Issue Type