jira
Thread
Date
Earlier messages
Later messages
Messages by Thread
Re: [PR] KAFKA-20211 [2/2]: Add group coordinator executor metrics [kafka]
via GitHub
Re: [PR] KAFKA-20211 [2/2]: Add group coordinator executor metrics [kafka]
via GitHub
[PR] KAFKA-20211 [1/2]: Change CoordinatorRuntime executor type from ExecutorService to ThreadPoolExecutor [kafka]
via GitHub
Re: [PR] KAFKA-20211 [1/2]: Change CoordinatorRuntime executor type from ExecutorService to ThreadPoolExecutor [kafka]
via GitHub
Re: [PR] KAFKA-20211 [1/2]: Change CoordinatorRuntime executor type from ExecutorService to ThreadPoolExecutor [kafka]
via GitHub
[jira] [Commented] (KAFKA-19939) ProductionExceptionHandler and DLQ does not support global thread
Arpit Goyal (Jira)
[jira] [Assigned] (KAFKA-9651) Divide by zero in DefaultPartitioner
Tom Bentley (Jira)
[jira] [Assigned] (KAFKA-9651) Divide by zero in DefaultPartitioner
Nilesh Kumar (Jira)
[jira] [Commented] (KAFKA-9651) Divide by zero in DefaultPartitioner
Nilesh Kumar (Jira)
[jira] [Commented] (KAFKA-9651) Divide by zero in DefaultPartitioner
Nilesh Kumar (Jira)
[jira] [Commented] (KAFKA-9651) Divide by zero in DefaultPartitioner
Tom Bentley (Jira)
[jira] [Commented] (KAFKA-9651) Divide by zero in DefaultPartitioner
Nilesh Kumar (Jira)
[PR] handling 0 partitions [kafka]
via GitHub
Re: [PR] handling 0 partitions [kafka]
via GitHub
Re: [PR] handling 0 partitions [kafka]
via GitHub
Re: [PR] handling 0 partitions [kafka]
via GitHub
Re: [PR] kAFKA-9651:handling 0 partitions [kafka]
via GitHub
Re: [PR] kAFKA-9651:handling 0 partitions [kafka]
via GitHub
Re: [PR] kAFKA-9651:Handle edge case when partition metadata contains zero partitions [kafka]
via GitHub
Re: [PR] kAFKA-9651:Handle edge case when partition metadata contains zero partitions [kafka]
via GitHub
Re: [PR] kAFKA-9651:Handle edge case when partition metadata contains zero partitions [kafka]
via GitHub
Re: [PR] kAFKA-9651:Handle edge case when partition metadata contains zero partitions [kafka]
via GitHub
[jira] [Commented] (KAFKA-20236) Allow kafka-configs.sh to delete all dynamic configs for a group
Jhen-Yung Hsu (Jira)
[jira] [Commented] (KAFKA-20236) Allow kafka-configs.sh to delete all dynamic configs for a group
David Jacot (Jira)
[jira] [Commented] (KAFKA-20236) Allow kafka-configs.sh to delete all dynamic configs for a group
Chia-Ping Tsai (Jira)
[jira] [Assigned] (KAFKA-20236) Allow kafka-configs.sh to delete all dynamic configs for a group
Jhen-Yung Hsu (Jira)
[jira] [Created] (KAFKA-20236) Allow kafka-configs.sh to delete all dynamic configs for a group
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-20236) Allow kafka-configs.sh to delete all dynamic configs for a group
Chia-Ping Tsai (Jira)
[PR] refactor: simplify code [kafka]
via GitHub
Re: [PR] KAFKA-20083: Move BrokerLifecycleManager to server module [kafka]
via GitHub
[PR] MINOR: remove `mapKey: true` from BrokerRegistrationRequest [kafka]
via GitHub
Re: [PR] MINOR: remove `mapKey: true` from BrokerRegistrationRequest [kafka]
via GitHub
Re: [PR] MINOR: remove `mapKey: true` from BrokerRegistrationRequest [kafka]
via GitHub
Re: [PR] MINOR: remove `mapKey: true` from BrokerRegistrationRequest [kafka]
via GitHub
Re: [PR] MINOR: remove `mapKey: true` from BrokerRegistrationRequest [kafka]
via GitHub
Re: [PR] MINOR: remove `mapKey: true` from BrokerRegistrationRequest [kafka]
via GitHub
Re: [PR] MINOR: remove `mapKey: true` from BrokerRegistrationRequest [kafka]
via GitHub
Re: [PR] MINOR: remove `mapKey: true` from BrokerRegistrationRequest [kafka]
via GitHub
Re: [PR] MINOR: remove `mapKey: true` from BrokerRegistrationRequest [kafka]
via GitHub
Re: [PR] MINOR: remove `mapKey: true` from BrokerRegistrationRequest [kafka]
via GitHub
Re: [PR] MINOR: remove `mapKey: true` from BrokerRegistrationRequest [kafka]
via GitHub
Re: [PR] MINOR: remove `mapKey: true` from BrokerRegistrationRequest [kafka]
via GitHub
Re: [PR] MINOR: remove `mapKey: true` from BrokerRegistrationRequest [kafka]
via GitHub
Re: [PR] MINOR: remove `mapKey: true` from BrokerRegistrationRequest [kafka]
via GitHub
[jira] [Commented] (KAFKA-20224) Revisit iterator adapters to see if these could use parameterized converter functions and eliminate code duplication
Mahesh Sambaram (Jira)
Re: [PR] KAFKA-1792: change behavior of --generate to produce assignment config with fair replica distribution and minimal number of reassignments [kafka]
via GitHub
Re: [PR] MINOR: Improve the `KAFKA_HEAP_OPTS` definition while run `kafka-server-start.bat` Batch [kafka]
via GitHub
Re: [PR] MINOR: Improve the `KAFKA_HEAP_OPTS` definition while run `kafka-server-start.bat` Batch [kafka]
via GitHub
Re: [PR] MINOR: Improve the `KAFKA_HEAP_OPTS` definition while run `kafka-server-start.bat` Batch [kafka]
via GitHub
Re: [PR] KAFKA-18996 Expose addReadOnlyStateStore in DSL (StreamsBuilder) [kafka]
via GitHub
Re: [PR] MINOR: Add startup-duration logging to help with Kafka startup performance tuning [kafka]
via GitHub
Re: [PR] KAFKA-19122: updateClusterMetadata receives multiples PartitionInfo [kafka]
via GitHub
[jira] [Assigned] (KAFKA-20235) Expose EffectiveMinIsr as a Partition metric
Lan Ding (Jira)
[jira] [Created] (KAFKA-20235) Expose EffectiveMinIsr as a Partition metric
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-20235) Expose EffectiveMinIsr as a Partition metric
Chia-Ping Tsai (Jira)
Re: [PR] KAFKA-15583: Enforce HWM advance only if partition is not under-min-ISR [kafka]
via GitHub
[PR] KAFKA-19863: Add documentation on how to implement a custom exception(with ref to DLQ) [kafka]
via GitHub
Re: [PR] KAFKA-19863: Add documentation on how to implement a custom exception(with ref to DLQ) [kafka]
via GitHub
[PR] Dddress KAFKA-13819 [kafka]
via GitHub
[PR] MINOR: Fix typo 'overidden' to 'overridden' in produce_consume_validate.py [kafka]
via GitHub
Re: [PR] MINOR: Fix typo 'overidden' to 'overridden' in produce_consume_validate.py [kafka]
via GitHub
[PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka]
via GitHub
Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka]
via GitHub
Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka]
via GitHub
Re: [PR] KAFKA-18590: Cleanup DelegationTokenManager [kafka]
via GitHub
Re: [PR] KAFKA-18590: Cleanup DelegationTokenManager [kafka]
via GitHub
Re: [PR] KAFKA-18590: Cleanup DelegationTokenManager [kafka]
via GitHub
[PR] KAFKA-20235: Replace System.out.println with proper logger for missing property file warning [kafka]
via GitHub
[jira] [Updated] (KAFKA-20234) Replace System.out.println with proper logger for missing property file warning
highluck (Jira)
[jira] [Created] (KAFKA-20234) Replace System.out.println with proper logger for missing property file warning
highluck (Jira)
Re: [PR] KAFKA-20158: Enable SessionStore with headers in DSL [kafka]
via GitHub
Re: [PR] KAFKA-20158: Enable SessionStore with headers in DSL [kafka]
via GitHub
Re: [PR] KAFKA-20158: Enable SessionStore with headers in DSL [kafka]
via GitHub
Re: [PR] KAFKA-20158: Enable SessionStore with headers in DSL [kafka]
via GitHub
Re: [PR] MINOR: Improve JavaDoc for LEAVING state transition in AbstractHeartbeatRequestManager [kafka]
via GitHub
Re: [PR] MINOR: Improve JavaDoc for LEAVING state transition in AbstractHeartbeatRequestManager [kafka]
via GitHub
Re: [PR] Add KafkaTopicCalculator feature [kafka]
via GitHub
Re: [PR] Feature/grade [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] KAFKA-17939: Make Bytes part of the public API (KIP-1247) [kafka]
via GitHub
Re: [PR] MINOR: Made shutdown request more robust. [kafka]
via GitHub
[jira] (KAFKA-20203) setFlushListener should pass record.headers() instead of empty headers
Nishant Kumar (Jira)
[jira] (KAFKA-20202) Verify existing IQv2 methods for MeteredTimestampedWindowStoreWithHeaders
Nishant Kumar (Jira)
[jira] [Resolved] (KAFKA-8416) Improve Documentation for Enabling Optimizations
Matthias J. Sax (Jira)
[jira] [Resolved] (KAFKA-8504) Update Docs to explain how to use suppress() in more details
Matthias J. Sax (Jira)
[jira] [Comment Edited] (KAFKA-13819) Add application.server to Streams assignor logs when set
Kartikay Dubey (Jira)
[jira] [Commented] (KAFKA-13819) Add application.server to Streams assignor logs when set
Kartikay Dubey (Jira)
[jira] [Commented] (KAFKA-13819) Add application.server to Streams assignor logs when set
Kartikay Dubey (Jira)
[jira] [Assigned] (KAFKA-13819) Add application.server to Streams assignor logs when set
Kartikay Dubey (Jira)
[jira] [Commented] (KAFKA-19571) Race condition between log segment flush and file deletion causing log dir to go offline
Ilyas Toumlilt (Jira)
[jira] [Updated] (KAFKA-19571) Race condition between log segment flush and file deletion causing log dir to go offline
Ilyas Toumlilt (Jira)
[jira] [Assigned] (KAFKA-20075) Side effects of 'preferred leader election' schedule change
Jonah Hooper (Jira)
[jira] [Commented] (KAFKA-20075) Side effects of 'preferred leader election' schedule change
Jonah Hooper (Jira)
[jira] [Updated] (KAFKA-20232) KafkaConsumer#commitAsync throws unexpected WakeupException in awaitMetadataUpdate()
Kirk True (Jira)
[jira] [Updated] (KAFKA-20109) Complete Kafka cluster dies on incorrect SSL config of a single controller
Jira
[jira] [Updated] (KAFKA-20109) Complete Kafka cluster dies on incorrect SSL config of a single controller
Sven Dewit (Jira)
[jira] [Resolved] (KAFKA-20013) Convert docs to Markdown
David Arthur (Jira)
[jira] [Commented] (KAFKA-20196) Deprecate Yammer-based metrics in `GroupCoordinatorMetrics` and add equivalent Kafka Metrics
Jira
[jira] [Resolved] (KAFKA-20229) Batch offset translation in RemoteClusterUtils
Mickael Maison (Jira)
[jira] [Assigned] (KAFKA-15143) MockFixedKeyProcessorContext is missing from test-utils
Uladzislau Blok (Jira)
[jira] [Resolved] (KAFKA-20053) Implement MockFixedKeyProcessorContext
Uladzislau Blok (Jira)
[jira] [Updated] (KAFKA-20053) Implement MockFixedKeyProcessorContext
Uladzislau Blok (Jira)
[jira] [Updated] (KAFKA-20053) Implement MockFixedKeyProcessorContext
Uladzislau Blok (Jira)
[jira] [Comment Edited] (KAFKA-20053) Implement MockFixedKeyProcessorContext
Uladzislau Blok (Jira)
[jira] [Resolved] (KAFKA-18866) JDK23: UnsupportedOperationException: getSubject is supported only if a security manager is allowed
Christian Habermehl (Jira)
[jira] [Updated] (KAFKA-18866) JDK23: UnsupportedOperationException: getSubject is supported only if a security manager is allowed
Matthias J. Sax (Jira)
[jira] [Resolved] (KAFKA-4875) Kafka Streams: topic groups and builder.stream API
Matthias J. Sax (Jira)
[jira] [Resolved] (KAFKA-10686) Pluggable standby tasks assignor for Kafka Streams
Matthias J. Sax (Jira)
[jira] [Assigned] (KAFKA-9828) Add partition to TestRecord in streams test-utils
Matthias J. Sax (Jira)
[jira] [Resolved] (KAFKA-8189) Streams should have an option to require names for stateful components
Matthias J. Sax (Jira)
[jira] [Resolved] (KAFKA-5158) Options for handling exceptions during processing
Matthias J. Sax (Jira)
[jira] [Commented] (KAFKA-20053) Implement MockFixedKeyProcessorContext
Matthias J. Sax (Jira)
[jira] [Commented] (KAFKA-20053) Implement MockFixedKeyProcessorContext
Uladzislau Blok (Jira)
[jira] [Assigned] (KAFKA-7371) Finally deprecate org.apache.kafka.common.serialization.ExtendedSerializer
Matthias J. Sax (Jira)
[jira] [Assigned] (KAFKA-14597) [Streams] record-e2e-latency-max is not reporting correct metrics
Matthias J. Sax (Jira)
[jira] [Assigned] (KAFKA-14597) [Streams] record-e2e-latency-max is not reporting correct metrics
Matthias J. Sax (Jira)
[jira] [Assigned] (KAFKA-8382) Add TimestampedSessionStore
Matthias J. Sax (Jira)
[jira] [Assigned] (KAFKA-10317) Global thread should honor shutdown signal during bootstrapping
Matthias J. Sax (Jira)
[jira] [Assigned] (KAFKA-20233) Add Broker + Controller Registrations to SamplingRequestLogFilter ADMIN_APIS
Kevin Wu (Jira)
[jira] [Created] (KAFKA-20233) Add Broker + Controller Registrations to SamplingRequestLogFilter ADMIN_APIS
Kevin Wu (Jira)
[jira] [Commented] (KAFKA-20232) KafkaConsumer#commitAsync throws unexpected WakeupException in awaitMetadataUpdate()
Brian Sang (Jira)
[jira] [Created] (KAFKA-20232) KafkaConsumer#commitAsync throws unexpected WakeupException in awaitMetadataUpdate()
Brian Sang (Jira)
[jira] [Resolved] (KAFKA-17865) Protocol documentation field names are sometimes ambiguous
Andrew Schofield (Jira)
[jira] [Resolved] (KAFKA-19962) Fix flaky ShareConsumerTest#testSubscribeOnInvalidTopicThrowsInvalidTopicException
Andrew Schofield (Jira)
[jira] [Resolved] (KAFKA-7841) KIP-419 Safely notify Kafka Connect SourceTask is stopped
Andrew Schofield (Jira)
[jira] [Updated] (KAFKA-20228) Do not allow add-controller to send localhost as endpoint
Kevin Wu (Jira)
[jira] [Updated] (KAFKA-20228) Do not allow add-controller to send localhost as endpoint
Kevin Wu (Jira)
[jira] [Updated] (KAFKA-20230) Allow globalTable to provide an optional KeyValueMapper to materialize an alternative K,V
Brandon Wittwer (Jira)
[jira] [Updated] (KAFKA-20230) Allow globalTable to provide an optional KeyValueMapper to materialize an alternative K,V
Brandon Wittwer (Jira)
[jira] [Updated] (KAFKA-20230) Allow globalTable to provide an optional KeyValueMapper to materialize an alternative K,V
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-20230) Allow globalTable to provide an optional KeyValueMapper to materialize an alternative K,V
Matthias J. Sax (Jira)
[jira] [Created] (KAFKA-20231) KIP-1290: Rack-Aware Minimum In-Sync Replicas
Karl Sorensen (Jira)
[jira] [Updated] (KAFKA-20230) globaltable processor
Brandon Wittwer (Jira)
[jira] [Updated] (KAFKA-20230) globaltable processor
Brandon Wittwer (Jira)
[jira] [Updated] (KAFKA-20230) globaltable processor
Brandon Wittwer (Jira)
[jira] [Updated] (KAFKA-20230) globaltable processor
Brandon Wittwer (Jira)
[jira] [Created] (KAFKA-20230) globaltable processor
Brandon Wittwer (Jira)
[jira] [Commented] (KAFKA-20205) Refactor serialization and deserialization code for *WithHeaders types
Guang Zhao (Jira)
[jira] [Assigned] (KAFKA-20205) Refactor serialization and deserialization code for *WithHeaders types
Guang Zhao (Jira)
[jira] [Updated] (KAFKA-20228) Add-controller can write leader's endpoint to log when promoting observer
Kevin Wu (Jira)
[jira] [Updated] (KAFKA-20228) Add-controller can write leader's endpoint to log when promoting observer
Kevin Wu (Jira)
[jira] [Created] (KAFKA-20229) Batch offset translation in RemoteClusterUtils
Mickael Maison (Jira)
[jira] [Created] (KAFKA-20228) Leader should use observer's reported listener when adding voter
Kevin Wu (Jira)
[jira] [Assigned] (KAFKA-18800) Deprecate Authorizer#aclCount
Ming-Yen Chung (Jira)
[jira] [Resolved] (KAFKA-20153) Upgrade ducktape from 0.12 to 0.13
Chia-Ping Tsai (Jira)
[jira] [Assigned] (KAFKA-10725) Merge StoreQueryIntegrationTest and QueryableStateIntegrationTest
Matthias J. Sax (Jira)
[PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (3/N) [kafka]
via GitHub
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (3/N) [kafka]
via GitHub
[jira] [Assigned] (KAFKA-20227) Break up KafkaRaftClient#poll() into different events
Kevin Wu (Jira)
[jira] [Commented] (KAFKA-20227) Break up KafkaRaftClient#poll() into different events
TaiJuWu (Jira)
[jira] [Commented] (KAFKA-20227) Break up KafkaRaftClient#poll() into different events
Kevin Wu (Jira)
[PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) [kafka]
via GitHub
[jira] [Assigned] (KAFKA-8504) Update Docs to explain how to use suppress() in more details
Matthias J. Sax (Jira)
[jira] [Assigned] (KAFKA-8504) Update Docs to explain how to use suppress() in more details
Matthias J. Sax (Jira)
[jira] [Assigned] (KAFKA-8416) Improve Documentation for Enabling Optimizations
Matthias J. Sax (Jira)
Re: [PR] MINOR: version update: 4.1.1 -->> 4.2.0 [kafka]
via GitHub
Re: [PR] MINOR: version update: 4.1.1 -->> 4.2.0 [kafka]
via GitHub
Earlier messages
Later messages