jira  

Messages by Thread

• [jira] [Assigned] (KAFKA-6987) Reimplement KafkaFuture with CopletableFuture Andras Beni (JIRA)
• [jira] [Assigned] (KAFKA-3362) Update protocol schema and field doc strings Andras Beni (JIRA)
• [jira] [Assigned] (KAFKA-7062) Simplify MirrorMaker loop after removal of old consumer support Andras Beni (JIRA)
• [jira] [Created] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes. Mark Tranter (JIRA)
• [jira] [Assigned] (KAFKA-7527) Enable Dependency Injection for Kafka Streams handlers (KIP-378) Guozhang Wang (JIRA)
• [jira] [Commented] (KAFKA-7062) Simplify MirrorMaker loop after removal of old consumer support Junyu Chen (JIRA)
  • [jira] [Commented] (KAFKA-7062) Simplify MirrorMaker loop after removal of old consumer support Andras Beni (JIRA)
  • [jira] [Commented] (KAFKA-7062) Simplify MirrorMaker loop after removal of old consumer support Junyu Chen (JIRA)
• [jira] [Updated] (KAFKA-7652) Kafka Streams Session store performance degradation from 0.10.2.2 to 0.11.0.0 Jonathan Gordon (JIRA)
• [jira] [Created] (KAFKA-7652) Kafka Streams Session store performance degradation from 0.10.2.2 to 0.11.0.0 Jonathan Gordon (JIRA)
• [jira] [Updated] (KAFKA-7632) Add producer option to adjust compression level Lee Dongjin (JIRA)
  • [jira] [Updated] (KAFKA-7632) Add producer option to adjust compression level Lee Dongjin (JIRA)
• [jira] [Resolved] (KAFKA-7402) Kafka Streams should implement AutoCloseable where appropriate Matthias J. Sax (JIRA)
• [jira] [Updated] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd Lee Dongjin (JIRA)
  • [jira] [Updated] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd Lee Dongjin (JIRA)
  • [jira] [Updated] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd Lee Dongjin (JIRA)
  • [jira] [Updated] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd Lee Dongjin (JIRA)
  • [jira] [Updated] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd Lee Dongjin (JIRA)
• [jira] [Assigned] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd Lee Dongjin (JIRA)
• [jira] [Commented] (KAFKA-7646) Flaky test SaslOAuthBearerSslEndToEndAuthorizationTest.testNoConsumeWithDescribeAclViaSubscribe Dong Lin (JIRA)
• [jira] [Updated] (KAFKA-7651) Flaky test SaslSslAdminClientIntegrationTest.testMinimumRequestTimeouts Dong Lin (JIRA)
• [jira] [Commented] (KAFKA-7651) Flaky test SaslSslAdminClientIntegrationTest.testMinimumRequestTimeouts Dong Lin (JIRA)
• [jira] [Issue Comment Deleted] (KAFKA-7312) Transient failure in kafka.api.AdminClientIntegrationTest.testMinimumRequestTimeouts Dong Lin (JIRA)
• [jira] [Created] (KAFKA-7651) Flaky test SaslSslAdminClientIntegrationTest.testMinimumRequestTimeouts Dong Lin (JIRA)
• [jira] [Comment Edited] (KAFKA-7312) Transient failure in kafka.api.AdminClientIntegrationTest.testMinimumRequestTimeouts Dong Lin (JIRA)
• [jira] [Commented] (KAFKA-7649) Flaky test SslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl Dong Lin (JIRA)
• [jira] [Commented] (KAFKA-7312) Transient failure in kafka.api.AdminClientIntegrationTest.testMinimumRequestTimeouts Dong Lin (JIRA)
• [jira] [Created] (KAFKA-7650) make "auto.create.topics.enable" dynamically configurable. xiongqi wu (JIRA)
• [jira] [Commented] (KAFKA-7648) Flaky test DeleteTopicsRequestTest.testValidDeleteTopicRequests Dong Lin (JIRA)
• [jira] [Comment Edited] (KAFKA-7648) Flaky test DeleteTopicsRequestTest.testValidDeleteTopicRequests Dong Lin (JIRA)
• [jira] [Comment Edited] (KAFKA-7486) Flaky test `DeleteTopicTest.testAddPartitionDuringDeleteTopic` Dong Lin (JIRA)
• [jira] [Commented] (KAFKA-7541) Transient Failure: kafka.server.DynamicBrokerReconfigurationTest.testUncleanLeaderElectionEnable Dong Lin (JIRA)
• [jira] [Updated] (KAFKA-7541) Transient Failure: kafka.server.DynamicBrokerReconfigurationTest.testUncleanLeaderElectionEnable Dong Lin (JIRA)
• [jira] [Created] (KAFKA-7646) Flaky test SaslOAuthBearerSslEndToEndAuthorizationTest.testNoConsumeWithDescribeAclViaSubscribe Dong Lin (JIRA)
• [jira] [Updated] (KAFKA-7649) Flaky test SslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl Dong Lin (JIRA)
• [jira] [Created] (KAFKA-7649) Flaky test SslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl Dong Lin (JIRA)
• [jira] [Updated] (KAFKA-7312) Transient failure in kafka.api.AdminClientIntegrationTest.testMinimumRequestTimeouts Dong Lin (JIRA)
  • [jira] [Updated] (KAFKA-7312) Transient failure in kafka.api.AdminClientIntegrationTest.testMinimumRequestTimeouts Dong Lin (JIRA)
• [jira] [Updated] (KAFKA-7648) Flaky test DeleteTopicsRequestTest.testValidDeleteTopicRequests Dong Lin (JIRA)
  • [jira] [Updated] (KAFKA-7648) Flaky test DeleteTopicsRequestTest.testValidDeleteTopicRequests Dong Lin (JIRA)
• [jira] [Created] (KAFKA-7648) Flaky test DeleteTopicsRequestTest.testValidDeleteTopicRequests Dong Lin (JIRA)
• [jira] [Updated] (KAFKA-7647) Flaky test LogCleanerParameterizedIntegrationTest.testCleansCombinedCompactAndDeleteTopic Dong Lin (JIRA)
  • [jira] [Updated] (KAFKA-7647) Flaky test LogCleanerParameterizedIntegrationTest.testCleansCombinedCompactAndDeleteTopic Dong Lin (JIRA)
• [jira] [Created] (KAFKA-7647) Flaky test LogCleanerParameterizedIntegrationTest.testCleansCombinedCompactAndDeleteTopic Dong Lin (JIRA)
• [jira] [Updated] (KAFKA-7646) Flaky test SaslOAuthBearerSslEndToEndAuthorizationTest.testNoConsumeWithDescribeAclViaSubscribe Dong Lin (JIRA)
• [jira] [Updated] (KAFKA-7486) Flaky test `DeleteTopicTest.testAddPartitionDuringDeleteTopic` Dong Lin (JIRA)
• [jira] [Created] (KAFKA-7645) Fix flaky unit test for 2.1 branch Dong Lin (JIRA)
• [jira] [Comment Edited] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker Boyang Chen (JIRA)
• [jira] [Created] (KAFKA-7644) Worker Re balance enhancements satya (JIRA)
• [jira] [Created] (KAFKA-7642) Kafka Connect - graceful shutdown of distributed worker satya (JIRA)
• [jira] [Commented] (KAFKA-5946) Give connector method parameter better name Samuel Hawker (JIRA)
• [jira] [Created] (KAFKA-7643) Connectors do not unload even when tasks fail in kafka connect satya (JIRA)
• [jira] [Comment Edited] (KAFKA-5946) Give connector method parameter better name Samuel Hawker (JIRA)
• [jira] [Comment Edited] (KAFKA-6567) KStreamWindowReduce can be replaced by KStreamWindowAggregate Samuel Hawker (JIRA)
• [jira] [Assigned] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker Boyang Chen (JIRA)
• [jira] [Commented] (KAFKA-6567) KStreamWindowReduce can be replaced by KStreamWindowAggregate Samuel Hawker (JIRA)
  • [jira] [Commented] (KAFKA-6567) KStreamWindowReduce can be replaced by KStreamWindowAggregate John Roesler (JIRA)
  • [jira] [Commented] (KAFKA-6567) KStreamWindowReduce can be replaced by KStreamWindowAggregate Guozhang Wang (JIRA)
• [jira] [Commented] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker Boyang Chen (JIRA)
  • [jira] [Commented] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker Stanislav Kozlovski (JIRA)
  • [jira] [Commented] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker Boyang Chen (JIRA)
  • [jira] [Commented] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker Stanislav Kozlovski (JIRA)
• [jira] [Updated] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker Boyang Chen (JIRA)
  • [jira] [Updated] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker Boyang Chen (JIRA)
  • [jira] [Updated] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker Boyang Chen (JIRA)
• [jira] [Created] (KAFKA-7641) Add `group.max.size` to cap group metadata on broker Boyang Chen (JIRA)
• [jira] [Created] (KAFKA-7640) Kafka stream interactive query not returning data when state is backed by rocksdb hitesh gollahalli bachanna (JIRA)
• [jira] [Commented] (KAFKA-7639) Read one request at a time from socket to reduce broker memory usage ASF GitHub Bot (JIRA)
• [jira] [Created] (KAFKA-7639) Read one request at a time from socket to reduce broker memory usage Rajini Sivaram (JIRA)
• [jira] [Commented] (KAFKA-7637) Error while writing to checkpoint file due to too many open files Ismael Juma (JIRA)
• [jira] [Updated] (KAFKA-7635) FetcherThread stops processing after "Error processing data for partition" Steven Aerts (JIRA)
• [jira] [Created] (KAFKA-7638) Trogdor - Support mass task creation endpoint Stanislav Kozlovski (JIRA)
• [jira] [Updated] (KAFKA-7637) Error while writing to checkpoint file due to too many open files Sander van Loo (JIRA)
• [jira] [Updated] (KAFKA-7636) Allow consumer to update maxPollRecords value Kcirtap Seven (JIRA)
• [jira] [Commented] (KAFKA-7636) Allow consumer to update maxPollRecords value ASF GitHub Bot (JIRA)
• [jira] [Created] (KAFKA-7637) ERROR Error while writing to checkpoint file due to too many open files Sander van Loo (JIRA)
• [jira] [Created] (KAFKA-7636) Allow consumer to update maxPollRecords value Kcirtap Seven (JIRA)
• [jira] [Resolved] (KAFKA-7565) NPE in KafkaConsumer Rajini Sivaram (JIRA)
• [jira] [Resolved] (KAFKA-7576) Dynamic update of replica fetcher threads may fail to start/close fetchers Rajini Sivaram (JIRA)
• [jira] [Commented] (KAFKA-7054) Kafka describe command should throw topic doesn't exist exception. ASF GitHub Bot (JIRA)
  • [jira] [Commented] (KAFKA-7054) Kafka describe command should throw topic doesn't exist exception. ASF GitHub Bot (JIRA)
• [jira] [Commented] (KAFKA-7635) FetcherThread stops processing after "Error processing data for partition" Steven Aerts (JIRA)
• [jira] [Created] (KAFKA-7635) FetcherThread stops processing after "Error processing data for partition" Steven Aerts (JIRA)
• [jira] [Resolved] (KAFKA-6774) Improve default groupId behavior in consumer Jason Gustafson (JIRA)
• [jira] [Resolved] (KAFKA-7628) KafkaStream is not closing Ozgur (JIRA)
• [jira] [Commented] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin() Guozhang Wang (JIRA)
  • [jira] [Commented] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin() Eugen Feller (JIRA)
  • [jira] [Commented] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin() Eugen Feller (JIRA)
  • [jira] [Commented] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin() Guozhang Wang (JIRA)
  • [jira] [Commented] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin() Eugen Feller (JIRA)
• [jira] [Created] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin() Eugen Feller (JIRA)
• [jira] [Commented] (KAFKA-7443) OffsetOutOfRangeException in restoring state store from changelog topic when start offset of local checkpoint is smaller than that of changelog topic John Roesler (JIRA)
• [jira] [Updated] (KAFKA-7584) StreamsConfig throws ClassCastException if max.in.flight.request.per.connect is specified as String Guozhang Wang (JIRA)
• [jira] [Updated] (KAFKA-7633) Kafka Connect requires permission to create internal topics even if they exist Arabelle Hou (JIRA)
  • [jira] [Updated] (KAFKA-7633) Kafka Connect requires permission to create internal topics even if they exist Arabelle Hou (JIRA)
  • [jira] [Updated] (KAFKA-7633) Kafka Connect requires permission to create internal topics even if they exist Arabelle Hou (JIRA)
• [jira] [Commented] (KAFKA-7633) Kafka Connect requires permission to create internal topics even if they exist ASF GitHub Bot (JIRA)
• [jira] [Created] (KAFKA-7633) Kafka Connect requires permission to create internal topics even if they exist Arabelle Hou (JIRA)
• [jira] [Commented] (KAFKA-7608) A Kafka Streams DSL transform or process call should potentially trigger a repartition Bill Bejeck (JIRA)
  • [jira] [Commented] (KAFKA-7608) A Kafka Streams DSL transform or process call should potentially trigger a repartition Andy Bryant (JIRA)
• [jira] [Created] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd Dave Waters (JIRA)
• [jira] [Assigned] (KAFKA-7631) NullPointerException when SCRAM is allowed bu ScramLoginModule is not in broker's jaas.conf Attila Sasvari (JIRA)
• [jira] [Commented] (KAFKA-7631) NullPointerException when SCRAM is allowed bu ScramLoginModule is not in broker's jaas.conf Andras Beni (JIRA)
• [jira] [Created] (KAFKA-7631) NullPointerException when SCRAM is allowed bu ScramLoginModule is not in broker's jaas.conf Andras Beni (JIRA)
• [jira] [Commented] (KAFKA-7630) Clarify that broker doesn't need scram username/password for delegation tokens Andras Beni (JIRA)
• [jira] [Created] (KAFKA-7630) Clarify that broker doesn't need scram username/password for delegation tokens Andras Beni (JIRA)
• [jira] [Resolved] (KAFKA-7626) Possible duplicate message delivery with exactly-once semantics Noam Berman (JIRA)
• [jira] [Commented] (KAFKA-7628) KafkaStream is not closing John Roesler (JIRA)
  • [jira] [Commented] (KAFKA-7628) KafkaStream is not closing Ozgur (JIRA)
  • [jira] [Commented] (KAFKA-7628) KafkaStream is not closing Guozhang Wang (JIRA)
  • [jira] [Commented] (KAFKA-7628) KafkaStream is not closing Ozgur (JIRA)
  • [jira] [Commented] (KAFKA-7628) KafkaStream is not closing Guozhang Wang (JIRA)
  • [jira] [Commented] (KAFKA-7628) KafkaStream is not closing Ozgur (JIRA)
  • [jira] [Commented] (KAFKA-7628) KafkaStream is not closing Guozhang Wang (JIRA)
• [jira] [Commented] (KAFKA-7626) Possible duplicate message delivery with exactly-once semantics Noam Berman (JIRA)
  • [jira] [Commented] (KAFKA-7626) Possible duplicate message delivery with exactly-once semantics Noam Berman (JIRA)
• [jira] [Updated] (KAFKA-7626) Possible duplicate message delivery with exactly-once semantics Noam Berman (JIRA)
  • [jira] [Updated] (KAFKA-7626) Possible duplicate message delivery with exactly-once semantics Noam Berman (JIRA)
• [jira] [Commented] (KAFKA-7620) ConfigProvider is broken for KafkaConnect when TTL is not null ASF GitHub Bot (JIRA)
• [jira] [Assigned] (KAFKA-7443) OffsetOutOfRangeException in restoring state store from changelog topic when start offset of local checkpoint is smaller than that of changelog topic John Roesler (JIRA)
• [jira] [Assigned] (KAFKA-7620) ConfigProvider is broken for KafkaConnect when TTL is not null Robert Yokota (JIRA)
• [jira] [Created] (KAFKA-7629) Mirror maker goes into infinite loop Darshan Mehta (JIRA)
• [jira] [Updated] (KAFKA-7629) Mirror maker goes into infinite loop Darshan Mehta (JIRA)
  • [jira] [Updated] (KAFKA-7629) Mirror maker goes into infinite loop Darshan Mehta (JIRA)
  • [jira] [Updated] (KAFKA-7629) Mirror maker goes into infinite loop Darshan Mehta (JIRA)
  • [jira] [Updated] (KAFKA-7629) Mirror maker goes into infinite loop Darshan Mehta (JIRA)
• [jira] [Assigned] (KAFKA-5505) Connect: Do not restart connector and existing tasks on task-set change Randall Hauch (JIRA)
• [jira] [Created] (KAFKA-7628) KafkaStream is not closing Ozgur (JIRA)
• [jira] [Updated] (KAFKA-7625) Kafka Broker node JVM crash - kafka.coordinator.transaction.TransactionCoordinator.$anonfun$handleEndTransaction JIRA
• [jira] [Created] (KAFKA-7627) Kafka server on Windows crashes with misspelled case in topic name Simon Rudchenko (JIRA)
• [jira] [Created] (KAFKA-7626) Possible duplicate message delivery with exactly-once semantics Noam Berman (JIRA)
• [jira] [Created] (KAFKA-7625) Kafka Broker node JVM crash - kafka.coordinator.transaction.TransactionCoordinator.$anonfun$handleEndTransaction JIRA
• [jira] [Created] (KAFKA-7624) HOW TO FILETER NESTED THROUGH KAFKA CONNECT Chenchu Lakshman kumar (JIRA)
• [jira] [Resolved] (KAFKA-7623) SMT STRUCT to MASK or FILTER Chenchu Lakshman kumar (JIRA)
• [jira] [Created] (KAFKA-7623) SMT STRUCT to MASK or FILTER Chenchu Lakshman kumar (JIRA)
• [jira] [Resolved] (KAFKA-4601) Avoid duplicated repartitioning in KStream DSL Bill Bejeck (JIRA)
• [jira] [Commented] (KAFKA-7621) Clients can't deal with server IP address change Edoardo Comar (JIRA)
• [jira] [Commented] (KAFKA-7606) Remove deprecated --zookeeper option from StreamsResetter Matthias J. Sax (JIRA)
  • [jira] [Commented] (KAFKA-7606) Remove deprecated --zookeeper option from StreamsResetter Srinivas Reddy (JIRA)
• [jira] [Commented] (KAFKA-7622) Add findSessions functionality to ReadOnlySessionStore Bill Bejeck (JIRA)
• [jira] [Updated] (KAFKA-7622) Add findSessions functionality to ReadOnlySessionStore Di Campo (JIRA)
  • [jira] [Updated] (KAFKA-7622) Add findSessions functionality to ReadOnlySessionStore Bill Bejeck (JIRA)
  • [jira] [Updated] (KAFKA-7622) Add findSessions functionality to ReadOnlySessionStore Bill Bejeck (JIRA)
  • [jira] [Updated] (KAFKA-7622) Add findSessions functionality to ReadOnlySessionStore Guozhang Wang (JIRA)
• [jira] [Created] (KAFKA-7622) Add findSessions functionality to ReadOnlySessionStore Di Campo (JIRA)
• [jira] [Created] (KAFKA-7621) Clients can't deal with server IP address change Bastian Voigt (JIRA)
• [jira] [Assigned] (KAFKA-7446) Better error message to explain the upper limit of TimeWindow Srinivas Reddy (JIRA)
• [jira] [Assigned] (KAFKA-7606) Remove deprecated --zookeeper option from StreamsResetter Srinivas Reddy (JIRA)
• [jira] [Commented] (KAFKA-7446) Better error message to explain the upper limit of TimeWindow Srinivas Reddy (JIRA)
  • [jira] [Commented] (KAFKA-7446) Better error message to explain the upper limit of TimeWindow Guozhang Wang (JIRA)
• [jira] [Commented] (KAFKA-7587) Support for Protocol Buffers Message Format in kafka-console-consumer script huxihx (JIRA)
• [jira] [Assigned] (KAFKA-7611) Eliminate compiler warnings in Kafka Ismael Juma (JIRA)
• [jira] [Resolved] (KAFKA-7605) Flaky Test `SaslMultiMechanismConsumerTest.testCoordinatorFailover` Ismael Juma (JIRA)
• [jira] [Resolved] (KAFKA-7612) Fix javac warnings and enable warnings as errors Ismael Juma (JIRA)
• [jira] [Updated] (KAFKA-7620) ConfigProvider is broken for KafkaConnect when TTL is not null Ye Ji (JIRA)
• [jira] [Updated] (KAFKA-7620) ConfigProvider is broken for connect when TTL is not null Ye Ji (JIRA)
• [jira] [Created] (KAFKA-7620) ConfigProvider is broken for connect when TTL is not null Ye Ji (JIRA)
• [jira] [Commented] (KAFKA-6958) Allow to define custom processor names with KStreams DSL ASF GitHub Bot (JIRA)
• [jira] [Commented] (KAFKA-7528) Standardize on Min/Avg/Max Kafka metrics' default value ASF GitHub Bot (JIRA)
• [jira] [Updated] (KAFKA-4453) add request prioritization Mayuresh Gharat (JIRA)
• [jira] [Resolved] (KAFKA-7452) Deleting snapshot files after check-pointing log recovery offsets can slow down replication when truncation happens Zhanxiang (Patrick) Huang (JIRA)
• [jira] [Updated] (KAFKA-7528) Standardize on Min/Avg/Max Kafka metrics' default value Stanislav Kozlovski (JIRA)
  • [jira] [Updated] (KAFKA-7528) Standardize on Min/Avg/Max Kafka metrics' default value Stanislav Kozlovski (JIRA)
• [jira] [Resolved] (KAFKA-7557) optimize LogManager.truncateFullyAndStartAt() Jun Rao (JIRA)
• [jira] [Created] (KAFKA-7619) Trogdor - Allow filtering tasks by state in /coordinator/tasks endpoint Stanislav Kozlovski (JIRA)
• [jira] [Commented] (KAFKA-7617) Document security primitives ASF GitHub Bot (JIRA)
• [jira] [Commented] (KAFKA-7618) Trogdor - Fix /tasks endpoint parameters Stanislav Kozlovski (JIRA)
  • [jira] [Commented] (KAFKA-7618) Trogdor - Fix /tasks endpoint parameters ASF GitHub Bot (JIRA)
• [jira] [Created] (KAFKA-7618) Trogdor - Fix /tasks endpoint parameters Stanislav Kozlovski (JIRA)
• [jira] [Commented] (KAFKA-5649) Producer is being closed generating ssl exception Behroz Sikander (JIRA)
• [jira] [Created] (KAFKA-7617) Document security primitives Viktor Somogyi (JIRA)
• [jira] [Commented] (KAFKA-7615) Support different topic name in source and destination server in Mirrormaker Adeeti Kaushal (JIRA)
  • [jira] [Commented] (KAFKA-7615) Support different topic name in source and destination server in Mirrormaker Ryanne Dolan (JIRA)
  • [jira] [Commented] (KAFKA-7615) Support different topic name in source and destination server in Mirrormaker James Cheng (JIRA)
• [jira] [Resolved] (KAFKA-7590) GETTING HUGE MESSAGE STRUCTURE THROUGH JMS CONNECTOR Chenchu Lakshman kumar (JIRA)
• [jira] [Created] (KAFKA-7616) MockConsumer can return ConsumerRecords objects with a non-empty map but no records JIRA
• [jira] [Commented] (KAFKA-7616) MockConsumer can return ConsumerRecords objects with a non-empty map but no records ASF GitHub Bot (JIRA)
• [jira] [Updated] (KAFKA-7615) Support different topic name in source and destination server in Mirrormaker Adeeti Kaushal (JIRA)
• [jira] [Created] (KAFKA-7615) Support different topic name in source and destination server in Mirrormaker Adeeti Kaushal (JIRA)
• [jira] [Assigned] (KAFKA-6812) Async ConsoleProducer exits with 0 status even after data loss Kamal Kang (JIRA)
• [jira] [Commented] (KAFKA-7612) Fix javac warnings and enable warnings as errors ASF GitHub Bot (JIRA)
• [jira] [Commented] (KAFKA-7418) Add '--help' option to all available Kafka CLI commands (KIP-374) ASF GitHub Bot (JIRA)
• [jira] [Created] (KAFKA-7614) Fix scalac warnings and enable warnings as errors Ismael Juma (JIRA)
• [jira] [Created] (KAFKA-7613) Enable javac rawtypes, serial and try xlint warnings Ismael Juma (JIRA)
• [jira] [Updated] (KAFKA-7613) Enable javac rawtypes, serial and try xlint warnings Ismael Juma (JIRA)
• [jira] [Created] (KAFKA-7612) Fix javac warnings and enable warnings as errors Ismael Juma (JIRA)
• [jira] [Created] (KAFKA-7611) Eliminate compiler warnings in Kafka Ismael Juma (JIRA)
• [jira] [Resolved] (KAFKA-7604) Flaky Test `ConsumerCoordinatorTest.testRebalanceAfterTopicUnavailableWithPatternSubscribe` Vahid Hashemian (JIRA)
• [jira] [Issue Comment Deleted] (KAFKA-7610) Detect consumer failures in initial JoinGroup Boyang Chen (JIRA)
• [jira] [Comment Edited] (KAFKA-7610) Detect consumer failures in initial JoinGroup Boyang Chen (JIRA)
  • [jira] [Comment Edited] (KAFKA-7610) Detect consumer failures in initial JoinGroup Jason Gustafson (JIRA)
  • [jira] [Comment Edited] (KAFKA-7610) Detect consumer failures in initial JoinGroup Boyang Chen (JIRA)
  • [jira] [Comment Edited] (KAFKA-7610) Detect consumer failures in initial JoinGroup Boyang Chen (JIRA)
  • [jira] [Comment Edited] (KAFKA-7610) Detect consumer failures in initial JoinGroup Jason Gustafson (JIRA)
• [jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup Boyang Chen (JIRA)
  • [jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup Boyang Chen (JIRA)
  • [jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup Jason Gustafson (JIRA)
  • [jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup Boyang Chen (JIRA)
  • [jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup Jason Gustafson (JIRA)
  • [jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup Boyang Chen (JIRA)

• Earlier messages