jira
Thread
Date
Earlier messages
Later messages
Messages by Thread
[PR] [WIP] KAFKA-19012: Messages ending up on the wrong topic [kafka]
via GitHub
Re: [PR] [WIP] KAFKA-19012: Messages ending up on the wrong topic [kafka]
via GitHub
Re: [PR] [WIP] KAFKA-19012: Messages ending up on the wrong topic [kafka]
via GitHub
[PR] [WIP] KAFKA-19012: Messages ending up on the wrong topic [kafka]
via GitHub
Re: [PR] [WIP] KAFKA-19012: Messages ending up on the wrong topic [kafka]
via GitHub
Re: [PR] [WIP] KAFKA-19012: Messages ending up on the wrong topic [kafka]
via GitHub
Re: [PR] [WIP] KAFKA-19012: Messages ending up on the wrong topic [kafka]
via GitHub
Re: [PR] [WIP] KAFKA-19012: Messages ending up on the wrong topic [kafka]
via GitHub
Re: [PR] [WIP] KAFKA-19012: Messages ending up on the wrong topic [kafka]
via GitHub
Re: [PR] [WIP] KAFKA-19012: Messages ending up on the wrong topic [kafka]
via GitHub
[PR] Minor: Use MV to enable ELR [kafka]
via GitHub
Re: [PR] MINOR: Bump LATEST_PRODUCTION to 4.1IV1 and Use MV to enable ELR [kafka]
via GitHub
Re: [PR] MINOR: Bump LATEST_PRODUCTION to 4.1IV1 and Use MV to enable ELR [kafka]
via GitHub
Re: [PR] MINOR: Bump LATEST_PRODUCTION to 4.1IV1 and Use MV to enable ELR [kafka]
via GitHub
Re: [PR] MINOR: Bump LATEST_PRODUCTION to 4.1IV1 and Use MV to enable ELR [kafka]
via GitHub
Re: [PR] MINOR: Bump LATEST_PRODUCTION to 4.1IV1 and Use MV to enable ELR [kafka]
via GitHub
Re: [PR] MINOR: Bump LATEST_PRODUCTION to 4.1IV1 and Use MV to enable ELR [kafka]
via GitHub
Re: [PR] MINOR: Bump LATEST_PRODUCTION to 4.1IV1 and Use MV to enable ELR [kafka]
via GitHub
Re: [PR] MINOR: Bump LATEST_PRODUCTION to 4.1IV1 and Use MV to enable ELR [kafka]
via GitHub
Re: [PR] MINOR: Bump LATEST_PRODUCTION to 4.1IV1 and Use MV to enable ELR [kafka]
via GitHub
Re: [PR] MINOR: Bump LATEST_PRODUCTION to 4.1IV1 and Use MV to enable ELR [kafka]
via GitHub
Re: [PR] MINOR: Bump LATEST_PRODUCTION to 4.1IV1 and Use MV to enable ELR [kafka]
via GitHub
Re: [PR] MINOR: Bump LATEST_PRODUCTION to 4.1IV1 and Use MV to enable ELR [kafka]
via GitHub
Re: [PR] MINOR: Bump LATEST_PRODUCTION to 4.1IV1 and Use MV to enable ELR [kafka]
via GitHub
Re: [PR] MINOR: Bump LATEST_PRODUCTION to 4.1IV1 and Use MV to enable ELR [kafka]
via GitHub
[jira] [Updated] (KAFKA-19478) Optimize sticky assignor
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-19477) Sticky Assignor JMH Benchmark
Matthias J. Sax (Jira)
[PR] KAFKA-19489: storage tool should check controller.quorum.voters is not set alongside a dynamic quorum flag when formatting [kafka]
via GitHub
Re: [PR] KAFKA-19489: storage tool should check controller.quorum.voters is not set alongside a dynamic quorum flag when formatting [kafka]
via GitHub
Re: [PR] KAFKA-19489: storage tool should check controller.quorum.voters is not set alongside a dynamic quorum flag when formatting [kafka]
via GitHub
Re: [PR] KAFKA-19489: storage tool should check controller.quorum.voters is not set alongside a dynamic quorum flag when formatting [kafka]
via GitHub
Re: [PR] KAFKA-19489: storage tool should check controller.quorum.voters is not set alongside a dynamic quorum flag when formatting [kafka]
via GitHub
Re: [PR] KAFKA-19489: storage tool should check controller.quorum.voters is not set alongside a dynamic quorum flag when formatting [kafka]
via GitHub
Re: [PR] KAFKA-19489: storage tool should check controller.quorum.voters is not set alongside a dynamic quorum flag when formatting [kafka]
via GitHub
Re: [PR] KAFKA-19489: storage tool should check controller.quorum.voters is not set alongside a dynamic quorum flag when formatting [kafka]
via GitHub
Re: [PR] KAFKA-19489: storage tool should check controller.quorum.voters is not set alongside a dynamic quorum flag when formatting [kafka]
via GitHub
Re: [PR] KAFKA-19489: storage tool should check controller.quorum.voters is not set alongside a dynamic quorum flag when formatting [kafka]
via GitHub
Re: [PR] KAFKA-19489: storage tool should check controller.quorum.voters is not set alongside a dynamic quorum flag when formatting [kafka]
via GitHub
[PR] KAFKA-19485: Added check before sending acknowledgements on initial epoch. [kafka]
via GitHub
Re: [PR] KAFKA-19485: Added check before sending acknowledgements on initial epoch. [kafka]
via GitHub
[PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-19213 Client ignores default properties [kafka]
via GitHub
Re: [PR] KAFKA-16717 [2/N]: Add AdminClient.alterShareGroupOffsets [kafka]
via GitHub
[jira] [Resolved] (KAFKA-19466) LogConcurrencyTest should close the log when the test completes
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19490) Remove usages of distutils in docker scripts
Mickael Maison (Jira)
[jira] [Updated] (KAFKA-19489) storage tool should check controller.quorum.voters is not set alongside a dynamic quorum flag when formatting
Kevin Wu (Jira)
[jira] [Updated] (KAFKA-19489) storage tool should check controller.quorum.voters is not set alongside a dynamic quorum flag when formatting
Kevin Wu (Jira)
[jira] [Updated] (KAFKA-19489) storage tool should check controller.quorum.voters is not set alongside a dynamic quorum flag when formatting
Kevin Wu (Jira)
[jira] [Updated] (KAFKA-19489) storage tool should check controller.quorum.voters is not set alongside a dynamic quorum flag when formatting
Jira
[jira] [Updated] (KAFKA-19489) storage tool should check controller.quorum.voters is not set alongside a dynamic quorum flag when formatting
Kevin Wu (Jira)
[jira] [Assigned] (KAFKA-19489) storage tool should check controller.quorum.voters is not set alongside a dynamic quorum flag when formatting
Kevin Wu (Jira)
[jira] [Created] (KAFKA-19489) storage tool should check controller.quorum.voters is not set alongside a dynamic quorum flag when formatting
Kevin Wu (Jira)
Re: [PR] KAFKA-19354: KRaft observer should fetch from leader after rediscovery [kafka]
via GitHub
[PR] KAFKA-19488: Update the docs of "if-not-exists" [kafka]
via GitHub
Re: [PR] KAFKA-19488: Update the docs of "if-not-exists" [kafka]
via GitHub
[jira] [Created] (KAFKA-19488) Update the docs of "if-not-exists"
Chia-Ping Tsai (Jira)
[PR] MINOR: Upgrade log4j to version 2.25.0 [kafka]
via GitHub
Re: [PR] MINOR: Upgrade log4j to version 2.25.0 [kafka]
via GitHub
Re: [PR] MINOR: Upgrade log4j to version 2.25.0 [kafka]
via GitHub
Re: [PR] MINOR: Upgrade log4j to version 2.25.0 [kafka]
via GitHub
[jira] [Created] (KAFKA-19487) Improve consistency of command-line arguments
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19486) Always use the latest version of kafka-topics.sh to create topics in system tests
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-19191) Don't load bootstrap.checkpoint files if the cluster is already bootstrapped
Mickael Maison (Jira)
[jira] [Commented] (KAFKA-18120) KIP-891: Support for multiple versions of connect plugins.
Mickael Maison (Jira)
[jira] [Resolved] (KAFKA-18120) KIP-891: Support for multiple versions of connect plugins.
Mickael Maison (Jira)
[jira] [Commented] (KAFKA-19248) Plugins Test for Multiversioning in Kafka Connect
Mickael Maison (Jira)
[jira] [Resolved] (KAFKA-19248) Plugins Test for Multiversioning in Kafka Connect
Mickael Maison (Jira)
[jira] [Updated] (KAFKA-14410) Allow connect runtime to run multiple versions of a connector.
Mickael Maison (Jira)
[jira] [Commented] (KAFKA-18297) Fix flaky PlaintextAdminIntegrationTest.testConsumerGroups
Mickael Maison (Jira)
[jira] [Commented] (KAFKA-14410) Allow connect runtime to run multiple versions of a connector.
Mickael Maison (Jira)
[jira] [Updated] (KAFKA-18297) Fix flaky PlaintextAdminIntegrationTest.testConsumerGroups
Mickael Maison (Jira)
[jira] [Commented] (KAFKA-18524) Fix flaky RemoteIndexCacheTest#testCorrectnessForCacheAndIndexFilesWhenResizeCache
Mickael Maison (Jira)
[jira] [Commented] (KAFKA-18879) Formatter for share group specific records in __consumer_offsets
Mickael Maison (Jira)
[jira] [Updated] (KAFKA-18879) Formatter for share group specific records in __consumer_offsets
Mickael Maison (Jira)
[jira] [Commented] (KAFKA-19191) Don't load bootstrap.checkpoint files if the cluster is already bootstrapped
Mickael Maison (Jira)
[jira] [Updated] (KAFKA-18524) Fix flaky RemoteIndexCacheTest#testCorrectnessForCacheAndIndexFilesWhenResizeCache
Mickael Maison (Jira)
[jira] [Commented] (KAFKA-19014) Potential race condition in remote-log-reader and remote-log-index-cleaner thread
Mickael Maison (Jira)
[jira] [Updated] (KAFKA-19014) Potential race condition in remote-log-reader and remote-log-index-cleaner thread
Mickael Maison (Jira)
[jira] [Updated] (KAFKA-19081) Share session capacity and eviction
Mickael Maison (Jira)
[jira] [Commented] (KAFKA-19081) Share session capacity and eviction
Mickael Maison (Jira)
[PR] MINOR: Refactor LockUtils and improve comments (follow up to KAFKA-19390) [kafka]
via GitHub
Re: [PR] MINOR: Refactor LockUtils and improve comments (follow up to KAFKA-19390) [kafka]
via GitHub
Re: [PR] MINOR: Refactor LockUtils and improve comments (follow up to KAFKA-19390) [kafka]
via GitHub
Re: [PR] MINOR: Refactor LockUtils and improve comments (follow up to KAFKA-19390) [kafka]
via GitHub
Re: [PR] MINOR: Refactor LockUtils and improve comments (follow up to KAFKA-19390) [kafka]
via GitHub
Re: [PR] MINOR: Refactor LockUtils and improve comments (follow up to KAFKA-19390) [kafka]
via GitHub
Re: [PR] MINOR: Refactor LockUtils and improve comments (follow up to KAFKA-19390) [kafka]
via GitHub
[PR] MINOR: Tidy up in AlterShareGroupOffsetsHandler [kafka]
via GitHub
Re: [PR] MINOR: Tidy up in AlterShareGroupOffsetsHandler [kafka]
via GitHub
Re: [PR] MINOR: Tidy up in AlterShareGroupOffsetsHandler [kafka]
via GitHub
Re: [PR] MINOR: Tidy up in AlterShareGroupOffsetsHandler [kafka]
via GitHub
[jira] [Resolved] (KAFKA-19444) SASL GSSAPI not working with librdkafka and AK 4.x
Mickael Maison (Jira)
[jira] [Resolved] (KAFKA-19457) Revisit the threshold to retry initialize share state RPC in group coordinator.
Andrew Schofield (Jira)
[jira] [Resolved] (KAFKA-19450) ShareConsumerPerformance does not handle exceptions from consumeMessagesForSingleShareConsumer
Andrew Schofield (Jira)
[jira] [Updated] (KAFKA-19485) Acknowledgements should not be sent on initial epoch of ShareFetch
Shivsundar R (Jira)
[jira] [Assigned] (KAFKA-10623) [Easy] Refactor code to avoid discovery conflicts for classes:{Supported|Finalized}VersionRange
Ksolves India Limited (Jira)
[jira] [Created] (KAFKA-19485) Acknowledgements should not be sent on initial epoch of ShareFetch
Shivsundar R (Jira)
[jira] [Assigned] (KAFKA-19485) Acknowledgements should not be sent on initial epoch of ShareFetch
Shivsundar R (Jira)
[jira] [Commented] (KAFKA-19484) Tiered Storage Quota Metrics can stop reporting
George Wu (Jira)
[jira] [Created] (KAFKA-19484) Tiered Storage Quota Metrics can stop reporting
George Wu (Jira)
[PR] [Tiered Storage] fix bug with throttle metrics [kafka]
via GitHub
Re: [PR] [KAFKA-19484] fix bug with tiered storage throttle metrics [kafka]
via GitHub
Re: [PR] [KAFKA-19484] fix bug with tiered storage throttle metrics [kafka]
via GitHub
Re: [PR] [KAFKA-19484] fix bug with tiered storage throttle metrics [kafka]
via GitHub
Re: [PR] [KAFKA-19484] fix bug with tiered storage throttle metrics [kafka]
via GitHub
Re: [PR] [KAFKA-19484] fix bug with tiered storage throttle metrics [kafka]
via GitHub
[jira] [Updated] (KAFKA-19482) Fix flaky test KafkaStreamsTelemetryIntegrationTest.shouldPassMetrics
Sushant Mahajan (Jira)
[jira] [Updated] (KAFKA-19482) Fix flaky test KafkaStreamsTelemetryIntegrationTest.shouldPassMetrics
Sushant Mahajan (Jira)
[jira] [Updated] (KAFKA-19482) Fix flaky test KafkaStreamsTelemetryIntegrationTest.shouldPassMetrics
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-19482) Fix flaky test KafkaStreamsTelemetryIntegrationTest.shouldPassMetrics
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-19483) Fix flaky test RemoteIndexCacheTest.testConcurrentCacheDeletedFileExists()
Sushant Mahajan (Jira)
[jira] [Commented] (KAFKA-16061) KRaft JBOD follow-ups and improvements
Colin McCabe (Jira)
[jira] [Resolved] (KAFKA-16061) KRaft JBOD follow-ups and improvements
Colin McCabe (Jira)
[jira] [Updated] (KAFKA-15367) Write a test verifying non-JBOD to JBOD transition
Colin McCabe (Jira)
[jira] [Updated] (KAFKA-15367) Write a test verifying a non-JBOD to JBOD transition in a cluster
Colin McCabe (Jira)
[jira] [Updated] (KAFKA-15367) Write a test verifying non-JBOD to JBOD migration
Colin McCabe (Jira)
[jira] [Updated] (KAFKA-15367) Test KRaft non-JBOD -> JBOD migration
Colin McCabe (Jira)
[jira] [Resolved] (KAFKA-15955) Migrating ZK brokers send dir assignments
Colin McCabe (Jira)
[jira] [Created] (KAFKA-19483) Fix flaky test RemoteIndexCacheTest.testConcurrentCacheDeletedFileExists()
Sushant Mahajan (Jira)
[jira] [Created] (KAFKA-19482) Fix flaky test KafkaStreamsTelemetryIntegrationTest.shouldPassMetrics
Sushant Mahajan (Jira)
[jira] [Updated] (KAFKA-19481) Fix flaky test AuthorizerIntegrationTest.testConsumerGroupHeartbeatWithRegex()
Sushant Mahajan (Jira)
[jira] [Updated] (KAFKA-19481) Fix flaky test AuthorizerIntegrationTest.testConsumerGroupHeartbeatWithRegex()
Sushant Mahajan (Jira)
[jira] [Created] (KAFKA-19481) Fix flaky test AuthorizerIntegrationTest.testConsumerGroupHeartbeatWithRegex()
Sushant Mahajan (Jira)
Re: [PR] KAFKA-18681 Created GetReplicaLogInfo* RPCs [kafka]
via GitHub
Re: [PR] KAFKA-17715: Remove argument force_use_zk_connection from kafka_acls_cmd_with_optional_security_settings [kafka]
via GitHub
Re: [PR] KAFKA-17715: Remove argument force_use_zk_connection from kafka_acls_cmd_with_optional_security_settings [kafka]
via GitHub
[jira] [Resolved] (KAFKA-7442) forceUnmap mmap on linux when index resize
Jun Rao (Jira)
[jira] [Resolved] (KAFKA-19390) AbstractIndex#resize() does not release old mmap on Linux
Jun Rao (Jira)
[jira] [Commented] (KAFKA-19012) Messages ending up on the wrong topic
Kirk True (Jira)
[jira] [Resolved] (KAFKA-19463) nextFetchOffset does not take ongoing state transition into account
Andrew Schofield (Jira)
[jira] [Assigned] (KAFKA-19471) Enable acknowledgement for a record which could not be deserialized
Andrew Schofield (Jira)
[jira] [Assigned] (KAFKA-19471) Enable acknowledgement for a record which could not be deserialized
Andrew Schofield (Jira)
[jira] [Updated] (KAFKA-19450) ShareConsumerPerformance does not handle exceptions from consumeMessagesForSingleShareConsumer
Andrew Schofield (Jira)
[jira] [Updated] (KAFKA-19450) ShareConsumerPerformance does not handle exceptions from consumeMessagesForSingleShareConsumer
Andrew Schofield (Jira)
[PR] KAFKA-19480: Recreate /migration when it has null value [kafka]
via GitHub
[PR] KAFKA-19478 [2/N]: Remove task pairs [kafka]
via GitHub
Re: [PR] KAFKA-19478 [2/N]: Remove task pairs [kafka]
via GitHub
Re: [PR] KAFKA-19478 [2/N]: Remove task pairs [kafka]
via GitHub
Re: [PR] KAFKA-19478 [2/N]: Remove task pairs [kafka]
via GitHub
Re: [PR] KAFKA-19478 [2/N]: Remove task pairs [kafka]
via GitHub
Re: [PR] KAFKA-19478 [2/N]: Remove task pairs [kafka]
via GitHub
Re: [PR] KAFKA-19478 [2/N]: Remove task pairs [kafka]
via GitHub
[jira] [Created] (KAFKA-19480) KRaft migration hangs when /migration has null value
Jira
[jira] [Commented] (KAFKA-19479) at_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees
Mihai Lucian (Jira)
[jira] [Commented] (KAFKA-19479) at_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees
Mihai Lucian (Jira)
[jira] [Commented] (KAFKA-19479) at_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees
Matthias J. Sax (Jira)
[jira] [Commented] (KAFKA-19479) at_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees
Shashank (Jira)
[PR] KAFKA-19450: MINOR: ShareConsumerPerformance does not handle exceptions from consumeMessagesForSingleShareConsumer [kafka]
via GitHub
Re: [PR] KAFKA-19450: MINOR: ShareConsumerPerformance does not handle exceptions from consumeMessagesForSingleShareConsumer [kafka]
via GitHub
Re: [PR] KAFKA-19450: ShareConsumerPerformance does not handle exceptions from consumeMessagesForSingleShareConsumer [kafka]
via GitHub
Re: [PR] KAFKA-19450: ShareConsumerPerformance does not handle exceptions from consumeMessagesForSingleShareConsumer [kafka]
via GitHub
[jira] [Updated] (KAFKA-19469) Dead-letter queues for share groups
Andrew Schofield (Jira)
[jira] [Updated] (KAFKA-19469) Dead-letter queues for share groups
Andrew Schofield (Jira)
[jira] [Updated] (KAFKA-19469) Dead-letter queues for share groups
Andrew Schofield (Jira)
[jira] [Assigned] (KAFKA-19479) at_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees
Mihai Lucian (Jira)
[jira] [Assigned] (KAFKA-19479) at_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees
Shashank (Jira)
[jira] [Commented] (KAFKA-19474) Wrong placement of WARN log for truncation below HWM
Rajani Karuturi (Jira)
[PR] KAFKA-19474: Fix wrong placement of WARN log for truncation below HWM [kafka]
via GitHub
Re: [PR] KAFKA-19474: Fix wrong placement of WARN log for truncation below HWM [kafka]
via GitHub
Re: [PR] KAFKA-19474: Fix wrong placement of WARN log for truncation below HWM [kafka]
via GitHub
Re: [PR] KAFKA-19474: Fix wrong placement of WARN log for truncation below HWM [kafka]
via GitHub
[jira] [Updated] (KAFKA-19479) at_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees
Mihai Lucian (Jira)
[jira] [Updated] (KAFKA-19479) at_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees
Mihai Lucian (Jira)
[jira] [Updated] (KAFKA-19479) at_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees
Mihai Lucian (Jira)
[jira] [Updated] (KAFKA-19479) at_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees
Mihai Lucian (Jira)
Earlier messages
Later messages