Re: [DISCUSS] KIP-1106: Add duration based offset reset option for consumer clients

d. We can follow your suggestions if we do not use Internal class approach, Thanks, On Wed, Nov 13, 2024 at 11:12 PM Jun Rao wrote: > Hi, Manikumar, > > Thanks for the updated KIP. > > JR10. The new AutoOffsetReset class. Could the following constructors be > private? >

Re: [DISCUSS] KIP-1106: Add duration based offset reset option for consumer clients

has the necessary getters. Of course, the KIP does not need to define > `AutoOffsetResetInternal` but only the public / user-facing > `AutoOffsetReset` class. > > > -Matthias > > On 11/7/24 10:23 PM, Manikumar wrote: > > Hi Matthias, > > > > Thanks for the comme

Re: [DISCUSS] KIP-1106: Add duration based offset reset option for consumer clients

concerns. Thanks, On Sat, Nov 9, 2024 at 10:06 PM Lianet M. wrote: > > Hi all. Thanks Manikumar for the nice improvement, useful indeed. > > I also lean towards having a single config given that it's all about the > reset policy, seems all the same "what" (auto reset p

Re: [DISCUSS] KIP-1106: Add duration based offset reset option for consumer clients

long as Optional, and use Optional.empty() for latest and earliest? > > Regards, > Apoorv Mittal > > > On Tue, Nov 12, 2024 at 12:06 PM Manikumar > wrote: > > > Thanks Ismael and Lianet for the reviews. > > > > Based on suggestions, I have updated the K

Re: [DISCUSS] KIP-1106: Add duration based offset reset option for consumer clients

Hi Andrew, Thanks for the review. AS4, AS5: Updated the KIP. AS6: Yes, it applies to both. updated the KIP. Thanks, On Tue, Nov 5, 2024 at 10:58 PM Andrew Schofield wrote: > > Hi Manikumar, > Thanks for the updates. A couple of other comments. > > AS4: I think the AK co

Re: [DISCUSS] KIP-1106: Add duration based offset reset option for consumer clients

, Nov 6, 2024 at 1:45 AM Apoorv Mittal wrote: > > Hi Manikumar, > Thanks for the changes. Just minor comment and a question: > > AM5: The description "How to initialize the share-partition start offset:" > for "*share.auto.offset.reset*" seems incomplete as it e

Re: [VOTE] KIP-1102: Enable clients to rebootstrap based on timeout or error code

Hi Rajini, Thanks for the KIP. +1 (binding). Thanks, On Tue, Nov 5, 2024 at 2:55 PM Rajini Sivaram wrote: > > Hi everyone, > > I would like to start vote on KIP-1102 ( > https://cwiki.apache.org/confluence/display/KAFKA/KIP-1102%3A+Enable+clients+to+rebootstrap+based+on+timeout+or+error+code).

Re: [DISCUSS] KIP-1106: Add duration based offset reset option for consumer clients

can add the new > class just for package `org.apache.kafka.streams` to avoid naming conflicts. > > Additionally, we would deprecate all methods taking existing enum > `AutoOffsetReset` (only two classed `Topology` and `Consumed` are > affected) and add new overload which accepts the

Re: [DISCUSS] KIP-1106: Add duration based offset reset option for consumer clients

of range scenarios. Thanks, On Fri, Nov 8, 2024 at 3:27 AM Jun Rao wrote: > > Hi, Manikumar, > > Thanks for the KIP. A couple of comments. > > JR1. It doesn't seem that we need earliest_local. Intuitively, it makes > sense for a consumer app to bootstrap based on time.

Re: [DISCUSS] KIP-1106: Add duration based offset reset option for consumer clients

Hi All, I have updated the KIP with recent suggestions. Thanks. On Fri, Nov 8, 2024 at 11:53 AM Manikumar wrote: > > Hi Matthias, > > Thanks for the comments. > > > I am personally not convinced that adding a new config > `auto.offset.reset.by.duration` is the best

Re: [DISCUSS] KIP-1106: Add duration based offset reset option for consumer clients

Hi All, I have made a minor update to the KIP. Since we are deprecating the OffsetResetStrategy enum, I have deprecated the `MockConsumer(OffsetResetStrategy offsetResetStrategy)` constructor and added a new constructor. Thanks, On Thu, Nov 14, 2024 at 10:25 AM Manikumar wrote: > Hi

Re: [VOTE] KIP-1106: Add duration based offset reset option for consumer clients

Thanks everyone for the votes. The vote passed with 6 binding votes (Kamal, David Arthur, Lianet, David Jacot, Jun, Matthias) and 2 non-binding votes (Andrew, Apoorv). Regards, Manikumar On Mon, Nov 18, 2024 at 2:41 PM Manikumar wrote: > Thanks Jun, > > Yes, Updated the KIP > &

Re: [DISCUSS] KIP-1106: Add duration based offset reset option for consumer clients

Hi Jun, JR10: Yes, we can remove the name field. Updated the KIP. Thanks, On Thu, Nov 14, 2024 at 3:57 AM Jun Rao wrote: > Hi, Manikumar, > > Thanks for the explanation. We can follow the existing KStreams pattern. > > Could AutoOffsetReset(String name, long dura

Re: [VOTE] KIP-1106: Add duration based offset reset option for consumer clients

Thanks Jun, Yes, Updated the KIP On Sat, Nov 16, 2024 at 1:21 AM Jun Rao wrote: > Hi, ManiKumar, > > Thanks for the KIP. +1 > > Should we document that duration can't be negative in the following too? > > AutoOffsetReset duration(Duration duration) > > Jun >

Re: [VOTE] KIP-1103: Additional metrics for cooperative consumption

Hi Apoorv, Thanks for the KIP. +1 (binding) Thanks On Thu, Nov 14, 2024 at 11:11 AM Chia-Ping Tsai wrote: > hi Apoorv > > Could you please add the link of vote thread to the KIP-1103 page? > > thanks, > Chia-Ping > > On 2024/11/07 11:14:03 Apoorv Mittal wrote: > > Hi All, > > I would like to

Re: [VOTE] KIP-1106: Add duration based offset reset option for consumer clients

raprak...@gmail.com> wrote: > > > Hi Manikumar, > > > > Thanks for the KIP! Duration based offset reset is a useful addition when > > remote storage is enabled. > > > > +1 (binding) > > > > Thanks, > > Kamal > > > > On Thu, Nov 14, 2024

[VOTE] KIP-1106: Add duration based offset reset option for consumer clients

Hi All, I would like to start start vote on KIP-1106: https://cwiki.apache.org/confluence/display/KAFKA/KIP-1106%3A+Add+duration+based+offset+reset+option+for+consumer+clients This KIP proposes to add an additional auto offset reset strategy for consumer clients. Regards, Manikumar

Re: [DISCUSS] KIP-1106: Add duration based offset reset option for consumer clients

ated `with(Topology.AutoOffsetReset)` method - added new `with(TimestampExtractor, AutoOffsetReset)` method - added new `with(TimestampExtractor, AutoOffsetReset)` method Thanks On Tue, Nov 19, 2024 at 5:36 PM Manikumar wrote: > Hi All, > > I have made a minor update to the

CVE-2024-56128: Apache Kafka: SCRAM authentication vulnerable to replay attacks when used without encryption

Severity: low Affected versions: - Apache Kafka 0.10.2.0 before 3.7.2 - Apache Kafka 3.8.0 Description: Incorrect Implementation of Authentication Algorithm in Apache Kafka's SCRAM implementation. Issue Summary: Apache Kafka's implementation of the Salted Challenge Response Authentication Mech

Re: [DISCUSS] KIP-1139: Add support for OAuth jwt-bearer grant type

configurations - A full end-to-end usage guide for the JWT bearer grant flow in Kafka Thanks, Manikumar On Sat, Mar 15, 2025 at 12:23 AM Kirk True wrote: > Hi all, > > I would like to start a discussion for KIP-1139: Add support for OAuth > jwt-bearer grant type: > > http

Re: [VOTE] KIP-1139: Add support for OAuth jwt-bearer grant type

Thanks for the detailed KIP. +1 (binding) Thanks, On Tue, May 6, 2025 at 3:24 AM Jun Rao wrote: > Hi, Kirk, > > Thanks for the KIP. +1 > > Jun > > On Fri, May 2, 2025 at 9:15 AM Kirk True wrote: > > > Hi, > > > > Thanks to all who provided feedback on KIP-1139: Add support for OAuth > > jwt-be

Re: [DISCUSS] KIP-1139: Add support for OAuth jwt-bearer grant type

c mechanism > to detect file changes”). Should we clarify it in the related *.file > configs, that it does support live rotation? > > Thanks! > > On Thu, Apr 24, 2025 at 7:46 PM Kirk True wrote: > > > Hi Manikumar, > > > > Update on the use of Keycloak for integ

Re: [VOTE] KIP-1135: Deprecated "org.apache.kafka.disallowed.login.modules"

Thanks for this KIP. +1 (binding) On Tue, May 20, 2025 at 5:42 PM 黃竣陽 wrote: > Thank for this KIP. > > +1 (non-binding) > > Best Regards, > Jiunn-Yang > > > Luke Chen 於 2025年5月20日 上午10:25 寫道： > > > > +1 (binding) from me. > > > > Thanks for the KIP. > > Luke > > > > On Mon, May 19, 2025 at 11:

[jira] [Resolved] (KAFKA-5462) Add a configuration for users to specify a template for building a custom principal name

[ https://issues.apache.org/jira/browse/KAFKA-5462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5462. -- Resolution: Fixed Fix Version/s: 2.2.0 > Add a configuration for users to specify a templ

[jira] [Resolved] (KAFKA-7535) KafkaConsumer doesn't report records-lag if isolation.level is read_committed

[ https://issues.apache.org/jira/browse/KAFKA-7535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7535. -- Resolution: Fixed > KafkaConsumer doesn't report records-lag if isolation.level is read_c

[jira] [Resolved] (KAFKA-7579) System Test Failure - security_test.SecurityTest.test_client_ssl_endpoint_validation_failure

[ https://issues.apache.org/jira/browse/KAFKA-7579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7579. -- Resolution: Fixed Fix Version/s: 2.1.0 This is fixed via KAFKA-7561. > System Test Fail

[jira] [Resolved] (KAFKA-7554) zookeeper.session.timeout.ms Value

[ https://issues.apache.org/jira/browse/KAFKA-7554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7554. -- Resolution: Not A Problem Default Zookeeper session timeout value 6 seconds. If the server fails to

[jira] [Resolved] (KAFKA-7323) add replication factor doesn't work

[ https://issues.apache.org/jira/browse/KAFKA-7323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7323. -- Resolution: Not A Problem Closing as per above comment. probably heap memory is not sufficient

[jira] [Resolved] (KAFKA-764) Race Condition in Broker Registration after ZooKeeper disconnect

[ https://issues.apache.org/jira/browse/KAFKA-764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-764. - Resolution: Duplicate This old issue is similar to KAFKA-7165. Closing this as duplicate KAFKA-7165

[jira] [Resolved] (KAFKA-7659) dummy test

[ https://issues.apache.org/jira/browse/KAFKA-7659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7659. -- Resolution: Invalid > dummy test > -- > > Key

[jira] [Resolved] (KAFKA-7616) MockConsumer can return ConsumerRecords objects with a non-empty map but no records

[ https://issues.apache.org/jira/browse/KAFKA-7616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7616. -- Resolution: Fixed Fix Version/s: 2.2.0 Issue resolved by pull request 5901 [https://github.com

[jira] [Resolved] (KAFKA-6971) Passing in help flag to kafka-console-producer should print arg options

[ https://issues.apache.org/jira/browse/KAFKA-6971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6971. -- Resolution: Duplicate > Passing in help flag to kafka-console-producer should print arg opti

[jira] [Resolved] (KAFKA-6149) LogCleanerManager should include topic partition name when warning of invalid cleaner offset

[ https://issues.apache.org/jira/browse/KAFKA-6149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6149. -- Resolution: Fixed Fix Version/s: 0.11.0.1 1.0.0 This was fixed in 1.0 and

[jira] [Resolved] (KAFKA-7259) Remove deprecated ZKUtils usage from ZkSecurityMigrator

[ https://issues.apache.org/jira/browse/KAFKA-7259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7259. -- Resolution: Fixed Issue resolved by pull request 5480 [https://github.com/apache/kafka/pull/5480

[jira] [Resolved] (KAFKA-7617) Document security primitives

[ https://issues.apache.org/jira/browse/KAFKA-7617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7617. -- Resolution: Fixed Fix Version/s: 2.2.0 Issue resolved by pull request 5906 [https://github.com

[jira] [Created] (KAFKA-7694) Support ZooKeeper based master/secret key management for delegation tokens

Manikumar created KAFKA-7694: Summary: Support ZooKeeper based master/secret key management for delegation tokens Key: KAFKA-7694 URL: https://issues.apache.org/jira/browse/KAFKA-7694 Project: Kafka

[jira] [Resolved] (KAFKA-7742) DelegationTokenCache#hmacIdCache entry is not cleared when a token is removed using removeToken(String tokenId) API.

[ https://issues.apache.org/jira/browse/KAFKA-7742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7742. -- Resolution: Fixed Fix Version/s: 2.2.0 Issue resolved by pull request 6037 [https://github.com

[jira] [Resolved] (KAFKA-7762) KafkaConsumer uses old API in the javadocs

[ https://issues.apache.org/jira/browse/KAFKA-7762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7762. -- Resolution: Fixed Fix Version/s: 2.2.0 Issue resolved by pull request 6052 [https://github.com

[jira] [Resolved] (KAFKA-7054) Kafka describe command should throw topic doesn't exist exception.

[ https://issues.apache.org/jira/browse/KAFKA-7054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7054. -- Resolution: Fixed Fix Version/s: 2.2.0 Issue resolved by pull request 5211 [https://github.com

[jira] [Resolved] (KAFKA-7752) zookeeper-security-migration.sh does not remove ACL on kafka-acl-extended

[ https://issues.apache.org/jira/browse/KAFKA-7752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7752. -- Resolution: Fixed Fix Version/s: 2.2.0 Issue resolved by pull request 6072 [https://github.com

[jira] [Resolved] (KAFKA-5994) Improve transparency of broker user ACL misconfigurations

[ https://issues.apache.org/jira/browse/KAFKA-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5994. -- Resolution: Fixed Fix Version/s: 2.2.0 Issue resolved by pull request 5021 [https://github.com

[jira] [Resolved] (KAFKA-7781) Add validation check for Topic retention.ms property

[ https://issues.apache.org/jira/browse/KAFKA-7781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7781. -- Resolution: Fixed Assignee: Kamal Chandraprakash Fix Version/s: 2.2.0 > Add validat

[jira] [Resolved] (KAFKA-6837) Apache kafka broker got stopped.

[ https://issues.apache.org/jira/browse/KAFKA-6837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6837. -- Resolution: Information Provided > Apache kafka broker got stop

[jira] [Resolved] (KAFKA-3921) Periodic refresh of metadata causes spurious log messages

[ https://issues.apache.org/jira/browse/KAFKA-3921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3921. -- Resolution: Auto Closed Closing inactive issue. The old producer is no longer supported. Please upgrade

[jira] [Resolved] (KAFKA-6825) DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG is private

[ https://issues.apache.org/jira/browse/KAFKA-6825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6825. -- Resolution: Fixed Assignee: Guozhang Wang Fix Version/s: 2.0.0

[jira] [Resolved] (KAFKA-6141) Errors logs when running integration/kafka/tools/MirrorMakerIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-6141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6141. -- Resolution: Fixed Closing this as log level changed to debug in ZOOKEEPER-2795 / Zookeeper 3.4.12

[jira] [Resolved] (KAFKA-6682) Kafka reconnection after broker restart

[ https://issues.apache.org/jira/browse/KAFKA-6682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6682. -- Resolution: Duplicate Resolving this as duplicate of KAFKA-6260.  Please reopen if the issue still

[jira] [Resolved] (KAFKA-6426) Kafka SASL/SCRAM authentication does not fail for incorrect username or password.

[ https://issues.apache.org/jira/browse/KAFKA-6426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6426. -- Resolution: Cannot Reproduce This looks like configuration issue. Please reopen if you think the issue

[jira] [Resolved] (KAFKA-1977) Make logEndOffset available in the Zookeeper consumer

[ https://issues.apache.org/jira/browse/KAFKA-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1977. -- Resolution: Auto Closed Closing this as the Scala consumers have been deprecated and no further work is

[jira] [Resolved] (KAFKA-3180) issue for extracting JSON from https web page

[ https://issues.apache.org/jira/browse/KAFKA-3180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3180. -- Resolution: Not A Problem  I suggest to post these kind of queries to  [[us...@kafka.apache.org

[jira] [Resolved] (KAFKA-3620) Clean up Protocol class.

[ https://issues.apache.org/jira/browse/KAFKA-3620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3620. -- Resolution: Fixed Closing this as some cleanup done in newer versions.  Please reopen if you think

[jira] [Resolved] (KAFKA-3843) Endless consuming messages in Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-3843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3843. -- Resolution: Auto Closed The Scala consumers have been deprecated and no further work is planned, please

[jira] [Resolved] (KAFKA-4091) Unable to produce or consume on any topic

[ https://issues.apache.org/jira/browse/KAFKA-4091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4091. -- Resolution: Cannot Reproduce {color:#00}Closing inactive issue. Please reopen if you think the

[jira] [Resolved] (KAFKA-5728) Stopping consumer thread cause loosing message in the partition

[ https://issues.apache.org/jira/browse/KAFKA-5728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5728. -- Resolution: Auto Closed looks like this is related to spring kafka config issue. must be related to

[jira] [Resolved] (KAFKA-3246) Transient Failure in kafka.producer.SyncProducerTest.testProduceCorrectlyReceivesResponse

[ https://issues.apache.org/jira/browse/KAFKA-3246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3246. -- Resolution: Auto Closed > Transient Failure

[jira] [Resolved] (KAFKA-5039) Logging in BlockingChannel and SyncProducer connect

[ https://issues.apache.org/jira/browse/KAFKA-5039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5039. -- Resolution: Auto Closed Closing as scala producer is removed from codebase. > Logging

[jira] [Resolved] (KAFKA-3345) ProducerResponse could gracefully handle no throttle time provided

[ https://issues.apache.org/jira/browse/KAFKA-3345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3345. -- Resolution: Auto Closed Closing as scala producer is removed from codebase. [|https://issues.apache.org

[jira] [Resolved] (KAFKA-2174) Wrong TopicMetadata deserialization

[ https://issues.apache.org/jira/browse/KAFKA-2174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2174. -- Resolution: Auto Closed Closing inactive issue. > Wrong TopicMetadata deserializat

[jira] [Resolved] (KAFKA-1460) NoReplicaOnlineException: No replica for partition

[ https://issues.apache.org/jira/browse/KAFKA-1460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1460. -- Resolution: Auto Closed Closing inactive issue.  Please reopen if you think the issue still exists in

[jira] [Resolved] (KAFKA-4419) Unable to GetOffset when the ACL of topic is defined

[ https://issues.apache.org/jira/browse/KAFKA-4419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4419. -- Resolution: Duplicate Resolving as duplicate of  KAFKA-3355. > Unable to GetOffset when the ACL

[jira] [Resolved] (KAFKA-5432) producer and consumer SocketTimeoutException

[ https://issues.apache.org/jira/browse/KAFKA-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5432. -- Resolution: Auto Closed Closing inactive issue.  Exceptions observed with deprecated scala clients

[jira] [Resolved] (KAFKA-2943) Transient Failure in kafka.producer.SyncProducerTest.testReachableServer

[ https://issues.apache.org/jira/browse/KAFKA-2943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2943. -- Resolution: Auto Closed > Transient Failure in kafka.producer.SyncProducerTest.testReachableSer

[jira] [Resolved] (KAFKA-6356) UnknownTopicOrPartitionException & NotLeaderForPartitionException and log deletion happening with retention bytes kept at -1.

[ https://issues.apache.org/jira/browse/KAFKA-6356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6356. -- Resolution: Not A Problem old data is discarded after log retention period or when the log reaches

[jira] [Resolved] (KAFKA-3793) Kafka Python Consumer library messages gets truncated

[ https://issues.apache.org/jira/browse/KAFKA-3793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3793. -- Resolution: Cannot Reproduce {color:#00}Closing inactive issue. Please reopen if you think the

[jira] [Resolved] (KAFKA-2036) Consumer and broker have different networks

[ https://issues.apache.org/jira/browse/KAFKA-2036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2036. -- Resolution: Duplicate Resolving this duplicate of KIP-235/KIP-302  > Consumer and broker h

[jira] [Resolved] (KAFKA-4505) Cannot get topic lag since kafka upgrade from 0.8.1.0 to 0.10.1.0

[ https://issues.apache.org/jira/browse/KAFKA-4505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4505. -- Resolution: Auto Closed {color:#00}Closing inactive issue. Please reopen if you think the issue

[jira] [Resolved] (KAFKA-6862) test toolchain

[ https://issues.apache.org/jira/browse/KAFKA-6862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6862. -- Resolution: Invalid Please reopen the Jira with more details. > test toolch

[jira] [Created] (KAFKA-6945) Add support to allow users to acquire delegation tokens for other users

Manikumar created KAFKA-6945: Summary: Add support to allow users to acquire delegation tokens for other users Key: KAFKA-6945 URL: https://issues.apache.org/jira/browse/KAFKA-6945 Project: Kafka

[jira] [Resolved] (KAFKA-6921) Remove old Scala producer and all related code, tests, and tools

[ https://issues.apache.org/jira/browse/KAFKA-6921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6921. -- Resolution: Fixed > Remove old Scala producer and all related code, tests, and to

[jira] [Resolved] (KAFKA-3649) Add capability to query broker process for configuration properties

[ https://issues.apache.org/jira/browse/KAFKA-3649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3649. -- Resolution: Fixed Requested features are added in  KIP-133: Describe and Alter Configs Admin APIs and

[jira] [Resolved] (KAFKA-6929) ZkData - Consumers offsets Zookeeper path is not correct

[ https://issues.apache.org/jira/browse/KAFKA-6929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6929. -- Resolution: Fixed Fix Version/s: 2.0.0 Fixed via https://github.com/apache/kafka/pull/5060

[jira] [Resolved] (KAFKA-5346) Kafka Producer Failure After Idle Time

[ https://issues.apache.org/jira/browse/KAFKA-5346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5346. -- Resolution: Not A Problem Closing as per above comment. Please reopen if you think the issue still

[jira] [Resolved] (KAFKA-6769) Upgrade jetty library version

[ https://issues.apache.org/jira/browse/KAFKA-6769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6769. -- Resolution: Fixed Fix Version/s: 2.0.0 Jetty version upgraded to 9.4.10.v20180503 in trunk

[jira] [Resolved] (KAFKA-4368) Unclean shutdown breaks Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-4368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4368. -- Resolution: Auto Closed Closing inactive issue. > Unclean shutdown breaks Kafka clus

[jira] [Resolved] (KAFKA-6427) Inconsistent exception type from KafkaConsumer.position

[ https://issues.apache.org/jira/browse/KAFKA-6427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6427. -- Resolution: Fixed Fix Version/s: 2.0.0 Fixed in https://github.com/apache/kafka/pull/5005

[jira] [Resolved] (KAFKA-3293) Consumers are not able to get messages.

[ https://issues.apache.org/jira/browse/KAFKA-3293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3293. -- Resolution: Cannot Reproduce Closing inactive issue. Please reopen if the issue still exists in newer

[jira] [Resolved] (KAFKA-2556) Corrupted index on log.dir updates

[ https://issues.apache.org/jira/browse/KAFKA-2556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2556. -- Resolution: Not A Problem Closing inactive issue. Kafka log.dir contains topic data and metadata

[jira] [Resolved] (KAFKA-3743) kafka-server-start.sh: Unhelpful error message

[ https://issues.apache.org/jira/browse/KAFKA-3743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3743. -- Resolution: Duplicate > kafka-server-start.sh: Unhelpful error mess

[jira] [Resolved] (KAFKA-6581) ConsumerGroupCommand hangs if even one of the partition is unavailable

[ https://issues.apache.org/jira/browse/KAFKA-6581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6581. -- Resolution: Fixed Fix Version/s: (was: 0.10.0.2) 2.0.0 This is addressed

[jira] [Resolved] (KAFKA-3177) Kafka consumer can hang when position() is called on a non-existing partition.

[ https://issues.apache.org/jira/browse/KAFKA-3177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3177. -- Resolution: Fixed This is addressed by KIP-266. > Kafka consumer can hang when position() is cal

[jira] [Resolved] (KAFKA-3503) Throw exception on missing/non-existent partition

[ https://issues.apache.org/jira/browse/KAFKA-3503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3503. -- Resolution: Duplicate > Throw exception on missing/non-existent partit

[jira] [Resolved] (KAFKA-3899) Consumer.poll() stuck in loop if wrong credentials are supplied

[ https://issues.apache.org/jira/browse/KAFKA-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3899. -- Resolution: Fixed Assignee: (was: Edoardo Comar) Fix Version/s: 2.0.0 This is

[jira] [Resolved] (KAFKA-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned

[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3727. -- Resolution: Fixed This is addressed by KIP-266. > Consumer.poll() stuck in loop on non-existent to

[jira] [Resolved] (KAFKA-3011) Consumer.poll(0) blocks if Kafka not accessible

[ https://issues.apache.org/jira/browse/KAFKA-3011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3011. -- Resolution: Fixed This is addressed by KIP-266.  > Consumer.poll(0) blocks if Kafka not accessi

[jira] [Resolved] (KAFKA-3822) Kafka Consumer close() hangs indefinitely if Kafka Broker shutdown while connected

[ https://issues.apache.org/jira/browse/KAFKA-3822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3822. -- Resolution: Fixed This is addressed by KIP-266.  > Kafka Consumer close() hangs indefinitely if Ka

[jira] [Resolved] (KAFKA-3457) KafkaConsumer.committed(...) hangs forever if port number is wrong

[ https://issues.apache.org/jira/browse/KAFKA-3457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3457. -- Resolution: Fixed This is addressed by KIP-266.  > KafkaConsumer.committed(...) hangs forever if p

[jira] [Resolved] (KAFKA-4571) Consumer fails to retrieve messages if started before producer

[ https://issues.apache.org/jira/browse/KAFKA-4571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4571. -- Resolution: Auto Closed Closing inactive issue. Please reopen if the issue still exists. > Consu

[jira] [Resolved] (KAFKA-4751) kafka-clients-0.9.0.2.4.2.11-1 issue not throwing exception.

[ https://issues.apache.org/jira/browse/KAFKA-4751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4751. -- Resolution: Fixed This is addressed by KIP-266.  > kafka-clients-0.9.0.2.4.2.11-1 issue not throw

[jira] [Resolved] (KAFKA-5304) Kafka Producer throwing infinite NullPointerExceptions

[ https://issues.apache.org/jira/browse/KAFKA-5304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5304. -- Resolution: Auto Closed Closing inactive issue. Please reopen if the issue still exists. > Ka

[jira] [Resolved] (KAFKA-5424) KafkaConsumer.listTopics() throws Exception when unauthorized topics exist in cluster

[ https://issues.apache.org/jira/browse/KAFKA-5424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5424. -- Resolution: Fixed This has been fixed via KAFKA-3396 > KafkaConsumer.listTopics() throws Except

[jira] [Resolved] (KAFKA-5940) kafka-delete-records.sh doesn't give any feedback when the JSON offset configuration file is invalid

[ https://issues.apache.org/jira/browse/KAFKA-5940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5940. -- Resolution: Fixed Fixed in KAFKA-5919 > kafka-delete-records.sh doesn't give any feedback

[jira] [Resolved] (KAFKA-6972) Kafka ACL does not work expected with wildcard

[ https://issues.apache.org/jira/browse/KAFKA-6972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6972. -- Resolution: Information Provided > Kafka ACL does not work expected with wildc

[jira] [Resolved] (KAFKA-5523) ReplayLogProducer not using the new Kafka consumer

[ https://issues.apache.org/jira/browse/KAFKA-5523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5523. -- Resolution: Fixed Assignee: Manikumar Fix Version/s: 2.0.0 > ReplayLogProducer

[jira] [Resolved] (KAFKA-6982) java.lang.ArithmeticException: / by zero

[ https://issues.apache.org/jira/browse/KAFKA-6982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6982. -- Resolution: Fixed Fix Version/s: 2.0.0 > java.lang.ArithmeticException: / by z

[jira] [Resolved] (KAFKA-6984) Question

[ https://issues.apache.org/jira/browse/KAFKA-6984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6984. -- Resolution: Information Provided Post these kind of queries to  [us...@kafka.apache.org|mailto:us

[jira] [Resolved] (KAFKA-2445) Failed test: kafka.producer.ProducerTest > testSendWithDeadBroker FAILED

[ https://issues.apache.org/jira/browse/KAFKA-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2445. -- Resolution: Auto Closed > Failed test: kafka.producer.ProducerTest > testSendWithDeadBroker

[jira] [Resolved] (KAFKA-6351) libs directory has duplicate javassist jars

[ https://issues.apache.org/jira/browse/KAFKA-6351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6351. -- Resolution: Fixed Fix Version/s: 2.0.0 Closing this as javassist jar is resolving to single

[jira] [Resolved] (KAFKA-2572) zk connection instability

[ https://issues.apache.org/jira/browse/KAFKA-2572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2572. -- Resolution: Auto Closed Closing inactive issue. Please reopen if the issue still exists in newer

[jira] [Resolved] (KAFKA-3379) Update tools relying on old producer to use new producer.

[ https://issues.apache.org/jira/browse/KAFKA-3379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3379. -- Resolution: Fixed Fix Version/s: 2.0.0 > Update tools relying on old producer to use

[jira] [Resolved] (KAFKA-1181) Consolidate brokerList and topicPartitionInfo in BrokerPartitionInfo

[ https://issues.apache.org/jira/browse/KAFKA-1181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1181. -- Resolution: Auto Closed Closing this as BrokerPartitionInfo class removed in  KAFKA-6921

<    1   2   3   4   5   6   7   8   9   10   >