[jira] [Resolved] (KAFKA-8428) Cleanup LogValidator#validateMessagesAndAssignOffsetsCompressed to assume single record batch only

[ https://issues.apache.org/jira/browse/KAFKA-8428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8428. -- Resolution: Fixed Fix Version/s: 2.3.0 > Cleanup

Build failed in Jenkins: kafka-trunk-jdk8 #3683

See Changes: [github] MINOR: Remove redundant checkpoint thread started field in [jason] MINOR: Set default `group.instance.id` in JoinGroupResponse to null [wangguoz] KAFKA-8430: unit test to make sure null

Build failed in Jenkins: kafka-2.3-jdk8 #21

See Changes: [cmccabe] MINOR: Auth operations must be null when talking to a pre-KIP-430 broker [matthias] MINOR: improve error message for Serde type miss match (#6801) [jason] MINOR: Set default

Build failed in Jenkins: kafka-trunk-jdk11 #578

See Changes: [github] MINOR: Remove redundant checkpoint thread started field in [jason] MINOR: Set default `group.instance.id` in JoinGroupResponse to null --

[jira] [Resolved] (KAFKA-6029) Controller should wait for the leader migration to finish before ack a ControlledShutdownRequest

[ https://issues.apache.org/jira/browse/KAFKA-6029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved KAFKA-6029. - Resolution: Fixed > Controller should wait for the leader migration to finish before ack a >

Build failed in Jenkins: kafka-trunk-jdk8 #3682

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H40 (ubuntu xenial) in workspace

[jira] [Resolved] (KAFKA-8430) Unit test to make sure `group.id` and `group.instance.id` won't affect each other

[ https://issues.apache.org/jira/browse/KAFKA-8430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8430. Resolution: Fixed > Unit test to make sure `group.id` and `group.instance.id` won't affect each >

Build failed in Jenkins: kafka-trunk-jdk8 #3681

See -- Started by an SCM change Started by an SCM change Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H29 (ubuntu xenial) in workspace

Build failed in Jenkins: kafka-trunk-jdk11 #577

See Changes: [github] MINOR: Auth operations must be null when talking to a pre-KIP-430 broker [github] MINOR: improve error message for Serde type miss match (#6801)

Build failed in Jenkins: kafka-trunk-jdk8 #3680

See Changes: [github] MINOR: Auth operations must be null when talking to a pre-KIP-430 broker [github] MINOR: improve error message for Serde type miss match (#6801)

Build failed in Jenkins: kafka-2.3-jdk8 #20

See Changes: [bill] HOTFIX: Fix wrong setting of Serde in `MeteredTimestampWindowStore` -- [...truncated 2.89 MB...] kafka.security.auth.ResourceTypeTest > testFromString

[jira] [Created] (KAFKA-8445) Flaky Test UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledByTopicOverride

Boyang Chen created KAFKA-8445: -- Summary: Flaky Test UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledByTopicOverride Key: KAFKA-8445 URL: https://issues.apache.org/jira/browse/KAFKA-8445

[jira] [Created] (KAFKA-8444) If broker sense that it is unhealthy, broker should remove itself as leader from all partitions that it is hosting as partition leader.

bijaya created KAFKA-8444: - Summary: If broker sense that it is unhealthy, broker should remove itself as leader from all partitions that it is hosting as partition leader. Key: KAFKA-8444 URL:

Re: [DISCUSS] KIP-439: Deprecate Interface WindowStoreIterator

Let's see what other think about (2) (3) Interesting. My reasoning follows the code: For example, `RocksDbKeyValueBytesStoreSupplier#metricsScope()`returns "rocksdb-state" and this is concatenated later in `MeteredKeyValueStore` that adds a tag key: metricScope + "-id" value:

[jira] [Created] (KAFKA-8443) Allow broker to select a preferred read replica for consumer

David Arthur created KAFKA-8443: --- Summary: Allow broker to select a preferred read replica for consumer Key: KAFKA-8443 URL: https://issues.apache.org/jira/browse/KAFKA-8443 Project: Kafka

Re: [DISCUSS] KIP-439: Deprecate Interface WindowStoreIterator

Hi Matthias, 2) Yes, this is how I meant it. I am still in favour of `value-by-...` instead of `get`, because it gives you immediately the meaning of the metric without the need to know the API of the stores. 3) I asked to avoid misunderstandings because in KIP-444, `-state-` is stated

Build failed in Jenkins: kafka-trunk-jdk8 #3679

See Changes: [bbejeck] HOTFIX: Fix wrong setting of Serde in `MeteredTimestampWindowStore` -- [...truncated 2.46 MB...] kafka.security.auth.SimpleAclAuthorizerTest >

Build failed in Jenkins: kafka-trunk-jdk11 #576

See Changes: [bbejeck] HOTFIX: Fix wrong setting of Serde in `MeteredTimestampWindowStore` -- [...truncated 2.47 MB...] org.apache.kafka.connect.json.JsonConverterTest >

Re: [DISCUSS] KIP-439: Deprecate Interface WindowStoreIterator

Thanks Bruno. I updated the KIP without changing the metric name yet -- want to discuss this first. 1) I am also ok to keep `all()` 2) That's a good idea. To make sure I understand your suggestion correctly, below the mapping between metric name an methods. (Some metric names are use by

[jira] [Created] (KAFKA-8442) Inconsistent ISR output in topic command when using --bootstrap-server

Jason Gustafson created KAFKA-8442: -- Summary: Inconsistent ISR output in topic command when using --bootstrap-server Key: KAFKA-8442 URL: https://issues.apache.org/jira/browse/KAFKA-8442 Project:

[jira] [Resolved] (KAFKA-7991) Add StreamsUpgradeTest for 2.2 release

[ https://issues.apache.org/jira/browse/KAFKA-7991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-7991. - Resolution: Duplicate Yep. Closing as a duplicate. > Add StreamsUpgradeTest for 2.2 release >

[jira] [Resolved] (KAFKA-7321) ensure timely processing of deletion requests in Kafka topic (Time-based log compaction)

[ https://issues.apache.org/jira/browse/KAFKA-7321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-7321. Resolution: Fixed Fix Version/s: 2.3.0 This was merged some time ago and will be in 2.3.0.

Re: [VOTE] KIP-464: Defaults for AdminClient#createTopic

Hello everyone - the PR is out and ready to review! https://github.com/apache/kafka/pull/6728/ On Fri, May 10, 2019 at 11:57 AM Almog Gavra wrote: > Thanks everyone for the comments and discussion! Closing the voting out > for this KIP: > > * 4 Binding (Randall, Manikumar, Colin, Gwen) > * 2

Re: [DISCUSS] KIP-471: Expose RocksDB Metrics in Kafka Streams

Hi, Thank you for your comments. @Bill: 1. It is like Guozhang wrote: - rocksdb-state-id is for key-value stores - rocksdb-session-state-id is for session stores - rocksdb-window-state-id is for window stores These tags are defined in the corresponding store builders and I think it is a good

[jira] [Created] (KAFKA-8441) CLONE - Flaky Test KStreamAggregationIntegrationTest#shouldReduceSessionWindows

Bruno Cadonna created KAFKA-8441: Summary: CLONE - Flaky Test KStreamAggregationIntegrationTest#shouldReduceSessionWindows Key: KAFKA-8441 URL: https://issues.apache.org/jira/browse/KAFKA-8441

[jira] [Created] (KAFKA-8440) Flaky Test KStreamAggregationIntegrationTest#shouldReduceSessionWindows

Bruno Cadonna created KAFKA-8440: Summary: Flaky Test KStreamAggregationIntegrationTest#shouldReduceSessionWindows Key: KAFKA-8440 URL: https://issues.apache.org/jira/browse/KAFKA-8440 Project: Kafka

Re: [DISCUSS] KIP-439: Deprecate Interface WindowStoreIterator

Hi all, My comments on this KIP: 1. I would use `all()` instead of `range()` because the functionality is immediately clear without the need to look at the parameter list. 2. I would decouple method names from metrics name, because this allows us to change one naming independently from the

Jenkins build is back to normal : kafka-2.3-jdk8 #19

See

Re: [DISCUSS] KIP-474: To deprecate WindowStore#put(key, value)

Hi Omkar, Looks good to me. Thanks! Is there anyone who has some comments about the KIP? Thanks, Dongjin On Tue, May 28, 2019 at 3:24 PM omkar mestry wrote: > Hi Dongjin, > > I have updated the KIP please have a look and provide feedback on it. > > KIP :- >

[jira] [Created] (KAFKA-8439) Readability issues on mobile phone

Daniel Noga created KAFKA-8439: -- Summary: Readability issues on mobile phone Key: KAFKA-8439 URL: https://issues.apache.org/jira/browse/KAFKA-8439 Project: Kafka Issue Type: Bug

Re: [DISCUSS] KIP-474: To deprecate WindowStore#put(key, value)

Hi Dongjin, I have updated the KIP please have a look and provide feedback on it. KIP :- https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=115526545 Thanks & Regards Omkar Mestry On Mon, May 27, 2019 at 6:25 PM Dongjin Lee wrote: > Hi Omkar, > > Thanks for the KIP. However,