jira
Thread
Date
Earlier messages
Later messages
Messages by Thread
Re: [PR] KAFKA-17747: Trigger rebalance on rack topology changes [kafka]
via GitHub
Re: [PR] KAFKA-17747: Trigger rebalance on rack topology changes [kafka]
via GitHub
Re: [PR] KAFKA-17747: Trigger rebalance on rack topology changes [kafka]
via GitHub
Re: [PR] KAFKA-17747: Trigger rebalance on rack topology changes [kafka]
via GitHub
[PR] KAFKA-19147: Start authorizer before group coordinator to ensure coordinator authorizes regex topics [kafka]
via GitHub
Re: [PR] KAFKA-19147: Start authorizer before group coordinator to ensure coordinator authorizes regex topics [kafka]
via GitHub
Re: [PR] KAFKA-19147: Start authorizer before group coordinator to ensure coordinator authorizes regex topics [kafka]
via GitHub
[PR] KAFKA-18854:Move DynamicConfig to server module [kafka]
via GitHub
Re: [PR] KAFKA-18854:Move DynamicConfig to server module [kafka]
via GitHub
Re: [PR] KAFKA-18854: Move DynamicConfig to server module [kafka]
via GitHub
Re: [PR] KAFKA-18854: Move `DynamicConfig User` and `DynamicConfig Client` to server module [kafka]
via GitHub
Re: [PR] KAFKA-18854: Move `DynamicConfig User` and `DynamicConfig Client` to server module [kafka]
via GitHub
Re: [PR] KAFKA-18854: Move `DynamicConfig User` and `DynamicConfig Client` to server module [kafka]
via GitHub
Re: [PR] KAFKA-18854: Move `DynamicConfig User` and `DynamicConfig Client` to server module [kafka]
via GitHub
Re: [PR] KAFKA-18854: Move `DynamicConfig User` and `DynamicConfig Client` to server module [kafka]
via GitHub
Re: [PR] KAFKA-18854: remove `DynamicConfig` inner class [kafka]
via GitHub
Re: [PR] KAFKA-18854: remove `DynamicConfig` inner class [kafka]
via GitHub
[PR] KAFKA-19112:cleanup.policy shouldn't be empty [kafka]
via GitHub
Re: [PR] KAFKA-19112:cleanup.policy shouldn't be empty [kafka]
via GitHub
Re: [PR] KAFKA-4243: Ensure metric names are quoted as necessary for JMX。 [kafka]
via GitHub
[jira] [Commented] (KAFKA-16061) KRaft JBOD follow-ups and improvements
kuper (Jira)
[PR] MINOR: Update GroupCoordinator interface to use AuthorizableRequestContext instead of RequestContext [kafka]
via GitHub
Re: [PR] MINOR: Update GroupCoordinator interface to use AuthorizableRequestContext instead of RequestContext [kafka]
via GitHub
Re: [PR] MINOR: Update GroupCoordinator interface to use AuthorizableRequestContext instead of RequestContext [kafka]
via GitHub
Re: [PR] MINOR: Update GroupCoordinator interface to use AuthorizableRequestContext instead of RequestContext [kafka]
via GitHub
Re: [PR] MINOR: Update GroupCoordinator interface to use AuthorizableRequestContext instead of RequestContext [kafka]
via GitHub
Re: [PR] MINOR: Update GroupCoordinator interface to use AuthorizableRequestContext instead of RequestContext [kafka]
via GitHub
Re: [PR] KAFAK-14604: SASL session expiration time will be overflowed when calculation [kafka]
via GitHub
Re: [PR] MINOR: Improvements for consumer package [kafka]
via GitHub
Re: [PR] MINOR: Improvements for consumer package [kafka]
via GitHub
Re: [PR] KAFKA-17075: Use new health check endpoint in Connect system tests to verify worker readiness [kafka]
via GitHub
Re: [PR] KAFKA-17075: Use new health check endpoint in Connect system tests to verify worker readiness [kafka]
via GitHub
[PR] MINOR: Upgrade Netty to 4.19 [kafka]
via GitHub
Re: [PR] MINOR: Upgrade Netty to 4.19 [kafka]
via GitHub
Re: [PR] MINOR: Upgrade Netty to 4.19 [kafka]
via GitHub
[PR] MINOR: Remove Kafka release section from root README [kafka]
via GitHub
Re: [PR] MINOR: Remove Kafka release section from root README [kafka]
via GitHub
Re: [PR] MINOR: Remove Kafka release section from root README [kafka]
via GitHub
Re: [PR] MINOR: Remove Kafka release section from root README [kafka]
via GitHub
Re: [PR] MINOR: Remove Kafka release section from root README [kafka]
via GitHub
Re: [PR] MINOR: Remove Kafka release section from root README [kafka]
via GitHub
[PR] MINOR: Replaced internal KafkaConfig field in TransactionLogConfig [kafka]
via GitHub
Re: [PR] MINOR: Replaced internal KafkaConfig field in TransactionLogConfig [kafka]
via GitHub
Re: [PR] MINOR: Replaced internal KafkaConfig field in TransactionLogConfig [kafka]
via GitHub
Re: [PR] MINOR: Replaced internal KafkaConfig field in TransactionLogConfig [kafka]
via GitHub
Re: [PR] MINOR: Replaced internal KafkaConfig field in TransactionLogConfig [kafka]
via GitHub
Re: [PR] MINOR: Replaced internal KafkaConfig field in TransactionLogConfig [kafka]
via GitHub
Re: [PR] MINOR: Replaced internal KafkaConfig field in TransactionLogConfig [kafka]
via GitHub
Re: [PR] MINOR: Replaced internal KafkaConfig field in TransactionLogConfig [kafka]
via GitHub
[jira] [Updated] (KAFKA-13610) Make log.cleaner.enable dynamically configurable
TengYao Chi (Jira)
[jira] [Updated] (KAFKA-13610) Make log.cleaner.enable dynamically configurable
TengYao Chi (Jira)
[PR] MINOR: Remove unused fields in KafkaConfig [kafka]
via GitHub
Re: [PR] MINOR: Remove unused fields in KafkaConfig [kafka]
via GitHub
[jira] [Commented] (KAFKA-17747) Trigger rebalance on rack topology changes
PoAn Yang (Jira)
[jira] [Assigned] (KAFKA-19144) Move DelayedProduce to server module
Szu-Yung Wang (Jira)
[PR] Minor: Streams thread safe position. [kafka]
via GitHub
Re: [PR] MINOR: Fix Streams Position thread-safety [kafka]
via GitHub
[PR] KAFKA-19151: docs: clarify that flush.ms requires log.flush.scheduler.interval.ms config [kafka]
via GitHub
Re: [PR] KAFKA-19151: docs: clarify that flush.ms requires log.flush.scheduler.interval.ms config [kafka]
via GitHub
Re: [PR] KAFKA-19151: docs: clarify that flush.ms requires log.flush.scheduler.interval.ms config [kafka]
via GitHub
Re: [PR] KAFKA-19151: docs: clarify that flush.ms requires log.flush.scheduler.interval.ms config [kafka]
via GitHub
Re: [PR] KAFKA-19151: docs: clarify that flush.ms requires log.flush.scheduler.interval.ms config [kafka]
via GitHub
Re: [PR] KAFKA-19151: docs: clarify that flush.ms requires log.flush.scheduler.interval.ms config [kafka]
via GitHub
Re: [PR] KAFKA-19151: docs: clarify that flush.ms requires log.flush.scheduler.interval.ms config [kafka]
via GitHub
Re: [PR] KAFKA-19151: docs: clarify that flush.ms requires log.flush.scheduler.interval.ms config [kafka]
via GitHub
Re: [PR] KAFKA-19151: docs: clarify that flush.ms requires log.flush.scheduler.interval.ms config [kafka]
via GitHub
Re: [PR] KAFKA-19151: docs: clarify that flush.ms requires log.flush.scheduler.interval.ms config [kafka]
via GitHub
Re: [PR] KAFKA-19151: docs: clarify that flush.ms requires log.flush.scheduler.interval.ms config [kafka]
via GitHub
[jira] [Created] (KAFKA-19154) Return INVALID_OFFSET if requested topic id does not match persisted one
David Jacot (Jira)
[jira] [Updated] (KAFKA-19153) Add OAuth integration tests using Keycloak
Kirk True (Jira)
[jira] [Updated] (KAFKA-19153) Add OAuth integration tests using Keycloak
Kirk True (Jira)
[jira] [Updated] (KAFKA-19153) Add OAuth integration tests using Keycloak
Kirk True (Jira)
[jira] [Updated] (KAFKA-19153) Add OAuth integration tests using Keycloak
Kirk True (Jira)
[jira] [Created] (KAFKA-19153) Add OAuth integration tests using Keycloak
Kirk True (Jira)
[jira] [Updated] (KAFKA-18847) Refactor OAuth layer to improve reusability
Kirk True (Jira)
[jira] [Created] (KAFKA-19152) Add top-level documentation for OAuth flows
Kirk True (Jira)
[jira] [Updated] (KAFKA-19152) Add top-level documentation for OAuth flows
Kirk True (Jira)
[jira] [Updated] (KAFKA-18573) Add support for OAuth jwt-bearer grant type
Kirk True (Jira)
[jira] [Updated] (KAFKA-19080) The constraint on segment.ms is not enforced at topic level
Jun Rao (Jira)
[jira] [Updated] (KAFKA-19080) The constraint on segment.ms is not enforced at topic level
Jun Rao (Jira)
[jira] [Assigned] (KAFKA-19151) Enhance the docs of flush.ms by reminding users the flush is triggered by log.flush.scheduler.interval.ms
Yunchi Pang (Jira)
[jira] [Created] (KAFKA-19151) Enhance the docs of flush.ms by reminding users the flush is triggered by log.flush.scheduler.interval.ms
Chia-Ping Tsai (Jira)
[PR] Added the ShareGroupStatePartitionMetadata record during deletion of share group offsets [kafka]
via GitHub
Re: [PR] Added the ShareGroupStatePartitionMetadata record during deletion of share group offsets [kafka]
via GitHub
Re: [PR] Added the ShareGroupStatePartitionMetadata record during deletion of share group offsets [kafka]
via GitHub
Re: [PR] Added the ShareGroupStatePartitionMetadata record during deletion of share group offsets [kafka]
via GitHub
Re: [PR] Added the ShareGroupStatePartitionMetadata record during deletion of share group offsets [kafka]
via GitHub
Re: [PR] Added the ShareGroupStatePartitionMetadata record during deletion of share group offsets [kafka]
via GitHub
Re: [PR] Added the ShareGroupStatePartitionMetadata record during deletion of share group offsets [kafka]
via GitHub
Re: [PR] Added the ShareGroupStatePartitionMetadata record during deletion of share group offsets [kafka]
via GitHub
Re: [PR] Added the ShareGroupStatePartitionMetadata record during deletion of share group offsets [kafka]
via GitHub
Re: [PR] Added the ShareGroupStatePartitionMetadata record during deletion of share group offsets [kafka]
via GitHub
Re: [PR] Added the ShareGroupStatePartitionMetadata record during deletion of share group offsets [kafka]
via GitHub
Re: [PR] Added the ShareGroupStatePartitionMetadata record during deletion of share group offsets [kafka]
via GitHub
Re: [PR] Added the ShareGroupStatePartitionMetadata record during deletion of share group offsets [kafka]
via GitHub
Re: [PR] Added the ShareGroupStatePartitionMetadata record during deletion of share group offsets [kafka]
via GitHub
Re: [PR] Added the ShareGroupStatePartitionMetadata record during deletion of share group offsets [kafka]
via GitHub
Re: [PR] Added the ShareGroupStatePartitionMetadata record during deletion of share group offsets [kafka]
via GitHub
Re: [PR] Added the ShareGroupStatePartitionMetadata record during deletion of share group offsets [kafka]
via GitHub
Re: [PR] Added the ShareGroupStatePartitionMetadata record during deletion of share group offsets [kafka]
via GitHub
Re: [PR] Added the ShareGroupStatePartitionMetadata record during deletion of share group offsets [kafka]
via GitHub
Re: [PR] KAFKA-16718-3/n: Added the ShareGroupStatePartitionMetadata record during deletion of share group offsets [kafka]
via GitHub
Re: [PR] KAFKA-16718-3/n: Added the ShareGroupStatePartitionMetadata record during deletion of share group offsets [kafka]
via GitHub
Re: [PR] KAFKA-16718-3/n: Added the ShareGroupStatePartitionMetadata record during deletion of share group offsets [kafka]
via GitHub
Re: [PR] KAFKA-16718-3/n: Added the ShareGroupStatePartitionMetadata record during deletion of share group offsets [kafka]
via GitHub
Re: [PR] KAFKA-16718-3/n: Added the ShareGroupStatePartitionMetadata record during deletion of share group offsets [kafka]
via GitHub
[jira] [Resolved] (KAFKA-18888) Add support for Authorizer
Mickael Maison (Jira)
[jira] [Assigned] (KAFKA-19149) Use KIP-877 in MirrorMaker
Kuan Po Tseng (Jira)
[jira] [Resolved] (KAFKA-18983) Ensure all README.md(s) are mentioned by the root README.md
Chia-Ping Tsai (Jira)
[jira] [Assigned] (KAFKA-19145) Move LeaderEndPoint to server module
Bolin Lin (Jira)
[jira] [Commented] (KAFKA-19146) Merge org.apache.kafka.server.common.OffsetAndEpoch and org.apache.kafka.raft.OffsetAndEpoch
Yu Chia Ma (Jira)
[jira] [Resolved] (KAFKA-19061) Add ACL changes to enable role based 2PC
Ritika Reddy (Jira)
[PR] 111 [kafka]
via GitHub
Re: [PR] 111 [kafka]
via GitHub
[PR] KAFKA-17897: Deprecate Admin.listConsumerGroups [kafka]
via GitHub
Re: [PR] KAFKA-17897: Deprecate Admin.listConsumerGroups [kafka]
via GitHub
Re: [PR] KAFKA-17897: Deprecate Admin.listConsumerGroups [kafka]
via GitHub
Re: [PR] KAFKA-17897: Deprecate Admin.listConsumerGroups [kafka]
via GitHub
Re: [PR] KAFKA-17897: Deprecate Admin.listConsumerGroups [kafka]
via GitHub
Re: [PR] KAFKA-17897: Deprecate Admin.listConsumerGroups [kafka]
via GitHub
Re: [PR] KAFKA-17897: Deprecate Admin.listConsumerGroups [kafka]
via GitHub
[PR] KAFKA-19082: [2/4] Add preparedTxnState class to Kafka Producer [kafka]
via GitHub
Re: [PR] KAFKA-19082: [2/4] Add preparedTxnState class to Kafka Producer (KIP-939) [kafka]
via GitHub
Re: [PR] KAFKA-19082: [2/4] Add preparedTxnState class to Kafka Producer (KIP-939) [kafka]
via GitHub
Re: [PR] KAFKA-19082: [2/4] Add preparedTxnState class to Kafka Producer (KIP-939) [kafka]
via GitHub
Re: [PR] KAFKA-19082: [2/4] Add preparedTxnState class to Kafka Producer (KIP-939) [kafka]
via GitHub
Re: [PR] KAFKA-19082: [2/4] Add preparedTxnState class to Kafka Producer (KIP-939) [kafka]
via GitHub
Re: [PR] KAFKA-19082: [2/4] Add preparedTxnState class to Kafka Producer (KIP-939) [kafka]
via GitHub
Re: [PR] KAFKA-19082: [2/4] Add preparedTxnState class to Kafka Producer (KIP-939) [kafka]
via GitHub
Re: [PR] KAFKA-19082: [2/4] Add preparedTxnState class to Kafka Producer (KIP-939) [kafka]
via GitHub
Re: [PR] KAFKA-19082: [2/4] Add preparedTxnState class to Kafka Producer (KIP-939) [kafka]
via GitHub
Re: [PR] KAFKA-19082: [2/4] Add preparedTxnState class to Kafka Producer (KIP-939) [kafka]
via GitHub
Re: [PR] KAFKA-19082: [2/4] Add preparedTxnState class to Kafka Producer (KIP-939) [kafka]
via GitHub
[PR] MINOR: update GitHub collaborators [kafka]
via GitHub
Re: [PR] MINOR: update GitHub collaborators [kafka]
via GitHub
[jira] [Created] (KAFKA-19144) Move DelayedProduce to server module
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-18594) Cleanup BrokerLifecycleManager
Manikumar (Jira)
Re: [PR] MINOR: Don't allow cloning a ProducerStateEntry with a different producer id [kafka]
via GitHub
[jira] [Created] (KAFKA-19145) Move LeaderEndPoint to server module
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-18786) Enable returnning supported features from a specific broker
PoAn Yang (Jira)
[jira] [Created] (KAFKA-19147) ConsumerGroupHeartbeat API leaks topic id and partition count of unauthorized topics
Rajini Sivaram (Jira)
[jira] [Updated] (KAFKA-19150) Consider renaming org.apache.kafka.storage.internals.log.RemoteStorageThreadPool metrics
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19146) Merge org.apache.kafka.server.common.OffsetAndEpoch and org.apache.kafka.raft.OffsetAndEpoch
Chia-Ping Tsai (Jira)
[jira] (KAFKA-19146) Merge org.apache.kafka.server.common.OffsetAndEpoch and org.apache.kafka.raft.OffsetAndEpoch
Yu Chia Ma (Jira)
[jira] [Assigned] (KAFKA-19150) Consider renaming org.apache.kafka.storage.internals.log.RemoteStorageThreadPool metrics
Jira
[jira] [Commented] (KAFKA-15599) Move classes in kafka.raft from core module to raft module
Ismael Juma (Jira)
[jira] [Resolved] (KAFKA-19113) Migrate DelegationTokenManager to server module
Mickael Maison (Jira)
[jira] [Updated] (KAFKA-18598) Remove ControllerMetadataMetrics zk related Metrics
Manikumar (Jira)
[jira] [Assigned] (KAFKA-15599) Move classes in kafka.raft from core module to raft module
Ismael Juma (Jira)
[jira] [Created] (KAFKA-19136) Merge MetadataLogConfig into KRaftConfigs
Chia-Ping Tsai (Jira)
[PR] KAFKA-19140 ConnectAssignor#performAssignment second parameter can be replace from String to ConnectProtocolCompatibility [kafka]
via GitHub
Re: [PR] KAFKA-19140 ConnectAssignor#performAssignment parameter can be replace to ConnectProtocolCompatibility [kafka]
via GitHub
Re: [PR] KAFKA-19140 ConnectAssignor#performAssignment parameter can be replace to ConnectProtocolCompatibility [kafka]
via GitHub
Re: [PR] KAFKA-19140 ConnectAssignor#performAssignment parameter can be replace to ConnectProtocolCompatibility [kafka]
via GitHub
[jira] [Created] (KAFKA-19150) Consider renaming org.apache.kafka.storage.internals.log.RemoteStorageThreadPool metrics
Mickael Maison (Jira)
[jira] [Resolved] (KAFKA-18902) Implement ShareConsumer option to throw on poll if there are unacked records
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19148) Potential Unclean Leader Election in KRaft Despite unclean.leader.election.enable=false
Julian Bergner (Jira)
[jira] [Resolved] (KAFKA-18845) Fail test QuorumControllerTest#testUncleanShutdownBrokerElrEnabled
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-19137) Use `StandardCharsets.UTF_8` instead of `StandardCharsets.UTF_8.name()`
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-19149) Use KIP-877 in MirrorMaker
Mickael Maison (Jira)
Re: [PR] KAFKA-14523: Move kafka.log.remote classes to storage [kafka]
via GitHub
Re: [PR] KAFKA-14523: Move kafka.log.remote classes to storage [kafka]
via GitHub
Re: [PR] KAFKA-14523: Move kafka.log.remote classes to storage [kafka]
via GitHub
Re: [PR] KAFKA-14523: Move kafka.log.remote classes to storage [kafka]
via GitHub
Re: [PR] KAFKA-14523: Move kafka.log.remote classes to storage [kafka]
via GitHub
[jira] [Created] (KAFKA-19149) Use KIP-877 in MirrorMaker
Mickael Maison (Jira)
[jira] [Resolved] (KAFKA-18900) Create a consumer config to select between implicit and explicit acknowledgement
Andrew Schofield (Jira)
[jira] [Updated] (KAFKA-19148) Potential Unclean Leader Election in KRaft Despite unclean.leader.election.enable=false
Julian Bergner (Jira)
[jira] [Updated] (KAFKA-19148) Potential Unclean Leader Election in KRaft Despite unclean.leader.election.enable=false
Julian Bergner (Jira)
[jira] [Updated] (KAFKA-19148) Potential Unclean Leader Election in KRaft Despite unclean.leader.election.enable=false
Julian Bergner (Jira)
[PR] KAFKA-19146: Merge OffsetAndEpoch from raft to server-common (Wip) [kafka]
via GitHub
Re: [PR] KAFKA-19146: Merge OffsetAndEpoch from raft to server-common [kafka]
via GitHub
Re: [PR] KAFKA-19146: Merge OffsetAndEpoch from raft to server-common [kafka]
via GitHub
Re: [PR] KAFKA-19146: Merge OffsetAndEpoch from raft to server-common [kafka]
via GitHub
Re: [PR] KAFKA-19146: Merge OffsetAndEpoch from raft to server-common [kafka]
via GitHub
Re: [PR] KAFKA-19146: Merge OffsetAndEpoch from raft to server-common [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19146) Merge org.apache.kafka.server.common.OffsetAndEpoch and org.apache.kafka.raft.OffsetAndEpoch
Yu Chia Ma (Jira)
[jira] [Updated] (KAFKA-19146) Merge org.apache.kafka.server.common.OffsetAndEpoch and org.apache.kafka.raft.OffsetAndEpoch
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-18871) KRaft migration rollback causes downtime
Luke Chen (Jira)
[jira] [Commented] (KAFKA-18871) KRaft migration rollback causes downtime
Daniel Urban (Jira)
Re: [PR] KAFKA-13610: Deprecate log.cleaner.enable configuration [kafka]
via GitHub
Re: [PR] KAFKA-13610: Deprecate log.cleaner.enable configuration [kafka]
via GitHub
Re: [PR] KAFKA-13610: Deprecate log.cleaner.enable configuration [kafka]
via GitHub
Re: [PR] KAFKA-13610: Deprecate log.cleaner.enable configuration [kafka]
via GitHub
Re: [PR] KAFKA-13610: Deprecate log.cleaner.enable configuration [kafka]
via GitHub
Re: [PR] KAFKA-13610: Deprecate log.cleaner.enable configuration [kafka]
via GitHub
Re: [PR] KAFKA-13610: Deprecate log.cleaner.enable configuration [kafka]
via GitHub
Re: [PR] KAFKA-13610: Deprecate log.cleaner.enable configuration [kafka]
via GitHub
Re: [PR] KAFKA-13610: Deprecate log.cleaner.enable configuration [kafka]
via GitHub
[jira] [Created] (KAFKA-19143) Setup periodic job to clean share group deleting metadata state in GC
Sushant Mahajan (Jira)
Re: [PR] KAFKA-19042: [4/N] Move PlaintextConsumerCallbackTest to client-integration-tests module [kafka]
via GitHub
Re: [PR] KAFKA-19042: [4/N] Move PlaintextConsumerCallbackTest to client-integration-tests module [kafka]
via GitHub
Re: [PR] KAFKA-18356 Explicitly setting up instrumentation for inline mocking (Java 21+) [kafka]
via GitHub
Re: [PR] KAFKA-18356 Explicitly setting up instrumentation for inline mocking (Java 21+) [kafka]
via GitHub
[jira] [Resolved] (KAFKA-18172) Move RemoteIndexCacheTest to storage module
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-19119) Move ApiVersionManager/SimpleApiVersionManager
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-19026) AlterConfigPolicy incompatibility between ZK mode and KRaft mode when using AlterConfigOp.OpType.SUBTRACT/APPEND
Luke Chen (Jira)
[jira] [Updated] (KAFKA-18592) Cleanup ReplicaManager
Manikumar (Jira)
[jira] [Updated] (KAFKA-18545) Remove Zookeeper logic from LogManager
Manikumar (Jira)
[PR] MINOR: improve (De)Serializer JavaDocs [kafka]
via GitHub
Earlier messages
Later messages