Jenkins build is back to normal : kafka-trunk-jdk11 #705

See

[jira] [Created] (KAFKA-8686) Flakey test ExampleConnectIntegrationTest#testSinkConnector

Boyang Chen created KAFKA-8686: -- Summary: Flakey test ExampleConnectIntegrationTest#testSinkConnector Key: KAFKA-8686 URL: https://issues.apache.org/jira/browse/KAFKA-8686 Project: Kafka Issue

Jenkins build is back to normal : kafka-2.2-jdk8 #152

See

Build failed in Jenkins: kafka-2.1-jdk8 #217

See Changes: [wangguoz] KAFKA-8615: Change to track partition time breaks TimestampExtractor -- [...truncated 465.89 KB...] kafka.server.KafkaConfigTest > testListenerAndAdve

Stopping All Tasks When a New Connector Added

Hi all, I have noticed that Kafka Connect 2.3.0 will stop all existing tasks and then start all the tasks, including the new tasks and the existing ones when adding a new connector or changing a connector configuration. However, I do not think it is a must. Only the new connector and tasks need

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

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

Re: [DISCUSS] KIP-491: Preferred Leader Deprioritized List (Temporary Blacklist)

Hi, Pinging the list for the feedbacks of this KIP-491   (https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=120736982)  Thanks, George On Saturday, July 13, 2019, 08:43:25 PM PDT, George Li wrote: Hi, I have created KIP-491 (https://cwiki.apache.org/confluence/page

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

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

Check the version of kafka information for MDT Mirror information

Hi, How to check version information for Kafka that is being used on the MDT Mirror servers? Is their any command to check that.I have any only access to Kafka and zookeeper servers through putty.Any help will be appreciated. Best Regards, bahir

Re: [VOTE] KIP-480 : Sticky Partitioner

+1 binding, looks like a nice improvement. Thanks! -David On Wed, Jul 17, 2019 at 6:17 PM Justine Olshan wrote: > Hello all, > > I wanted to let you all know the KIP has been updated. The > ComputedPartition class has been removed in favor of simply returning an > integer to represent the recor

Re: [VOTE] KIP-455: Create an Administrative API for Replica Reassignment

+1 (non-binding) Thanks for addressing the comments.  George On Thursday, July 18, 2019, 05:03:58 PM PDT, Gwen Shapira wrote: Renewing my +1, thank you Colin and Stan for working through all the questions, edge cases, requests and alternatives. We ended up with a great protocol. On

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

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

Re: [VOTE] KIP-488: Clean up Sum,Count,Total Metrics

+1 (binding) On 7/17/19 1:20 PM, Bill Bejeck wrote: > +1 (binding) for the updated KIP. > > On Wed, Jul 17, 2019 at 4:09 PM John Roesler wrote: > >> Hey, Bruno and Bill, >> >> Since you cast your votes before the KIP was updated, do you mind >> re-casting just so we can be sure you're still in

Re: [DISCUSS] KIP-488: Clean up Sum,Count,Total Metrics

Thanks for the background John. I am happy with `Windowed` and `Cumulative`, too. -Matthias On 7/17/19 11:22 AM, Ryanne Dolan wrote: > John, makes sense to me! Thanks. > > Ryanne > > On Wed, Jul 17, 2019, 1:16 PM John Roesler wrote: > >> Agreed. I think the names are actually not ambiguous

Re: [DISCUSS] KIP-466: Add support for List serialization and deserialization

Thanks! One minor question about the configs. The KIP adds three classes, a Serializer, a Deserializer, and a Serde. Hence, would it make sense to add the corresponding configs to `ConsumerConfig`, `ProducerConfig`, and `StreamsConfig` using slightly different names each time? Somethin like thi

Re: [VOTE] KIP-455: Create an Administrative API for Replica Reassignment

Renewing my +1, thank you Colin and Stan for working through all the questions, edge cases, requests and alternatives. We ended up with a great protocol. On Thu, Jul 18, 2019 at 4:54 PM Jason Gustafson wrote: > > +1 Thanks for the KIP. Really looking forward to this! > > -Jason > > On Wed, Jul 17

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

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

Re: [VOTE] KIP-455: Create an Administrative API for Replica Reassignment

+1 Thanks for the KIP. Really looking forward to this! -Jason On Wed, Jul 17, 2019 at 1:41 PM Colin McCabe wrote: > Thanks, Stanislav. Let's restart the vote to reflect the fact that we've > made significant changes. The new vote will go for 3 days as usual. > > I'll start with my +1 (binding

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

See Changes: [jason] KAFKA-8670; Fix exception for kafka-topics.sh --describe without --topic -- [...truncated 2.60 MB...] org.apache.kafka.connect.storage.SimpleHeaderCo

Build failed in Jenkins: kafka-2.2-jdk8 #151

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

Re: [DISCUSS] KIP-447: Producer scalability for exactly once semantics

Thank you Jason for the ideas. On Mon, Jul 15, 2019 at 5:28 PM Jason Gustafson wrote: > Hi Boyang, > > Thanks for the updates. A few comments below: > > 1. The KIP mentions that `transaction.timeout.ms` should be reduced to > 10s. > I think this makes sense for Kafka Streams which is tied to the

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

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

[jira] [Resolved] (KAFKA-8635) Unnecessary wait when looking up coordinator before transactional request

[ https://issues.apache.org/jira/browse/KAFKA-8635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8635. Resolution: Fixed Fix Version/s: 2.3.1 2.4.0 > Unnecessary wait w

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

See Changes: [jason] KAFKA-8635; Skip client poll in Sender loop when no request is sent -- Started by an SCM change [EnvInject] - Loading node environment variables. Buil

Build failed in Jenkins: kafka-2.2-jdk8 #150

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

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

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

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

See Changes: [jason] KAFKA-8670; Fix exception for kafka-topics.sh --describe without --topic [wangguoz] KAFKA-8615: Change to track partition time breaks TimestampExtractor

Build failed in Jenkins: kafka-2.2-jdk8 #149

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

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

See Changes: [jason] KAFKA-8670; Fix exception for kafka-topics.sh --describe without --topic -- Started by an SCM change [EnvInject] - Loading node environment variables. Bui

[jira] [Resolved] (KAFKA-8053) kafka-topics.sh gives confusing error message when the topic doesn't exist

[ https://issues.apache.org/jira/browse/KAFKA-8053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8053. Resolution: Fixed Fix Version/s: 2.3.1 2.4.0 This was resolved by

[jira] [Resolved] (KAFKA-8670) kafka-topics.sh shows IllegalArgumentException when describing all topics if no topics exist on the cluster

[ https://issues.apache.org/jira/browse/KAFKA-8670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8670. Resolution: Fixed Fix Version/s: 2.3.1 2.4.0 > kafka-topics.sh sh

Re: [DISCUSS] KIP-444: Augment Metrics for Kafka Streams

I mean the partition time. On Thu, Jul 18, 2019 at 11:29 AM Guozhang Wang wrote: > Hi Boyang, > > What do you mean by `per partition latency`? > > Guozhang > > On Mon, Jul 1, 2019 at 9:28 AM Boyang Chen > wrote: > > > Hey Guozhang, > > > > do we plan to add per partition latency in this KIP? >

[jira] [Resolved] (KAFKA-8685) groupInstanceId should be encoded within the consumer protocol

[ https://issues.apache.org/jira/browse/KAFKA-8685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8685. Resolution: Fixed Close this because in fact we pass the instance id from join group response memb

[jira] [Created] (KAFKA-8685) groupInstanceId should be encoded within the consumer protocol

Boyang Chen created KAFKA-8685: -- Summary: groupInstanceId should be encoded within the consumer protocol Key: KAFKA-8685 URL: https://issues.apache.org/jira/browse/KAFKA-8685 Project: Kafka Iss

Build failed in Jenkins: kafka-2.2-jdk8 #148

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

Re: [VOTE] KIP-466: Add support for List serialization and deserialization

+1 (binding). Thanks Daniyar! Guozhang On Tue, Jul 16, 2019 at 2:13 PM John Roesler wrote: > Thanks, Daniyar! > > I'm +1 (nonbinding) > > -John > > On Tue, Jul 16, 2019 at 3:14 PM Development wrote: > > > > Hi, > > > > I’d like to start a vote thread for KIP-466. > > > > This addition will in

Re: [DISCUSS] KIP-444: Augment Metrics for Kafka Streams

Hi Boyang, What do you mean by `per partition latency`? Guozhang On Mon, Jul 1, 2019 at 9:28 AM Boyang Chen wrote: > Hey Guozhang, > > do we plan to add per partition latency in this KIP? > > On Mon, Jul 1, 2019 at 7:08 AM Bruno Cadonna wrote: > > > Hi Guozhang, > > > > Thank you for the KIP.

Re: [DISCUSS] KIP-444: Augment Metrics for Kafka Streams

Good catch! Will update the wiki. On Wed, Jul 3, 2019 at 6:19 AM Bruno Cadonna wrote: > Hi Guozhang, > > I just noticed that the Per-State-Store tags are somehow mixed up in > the KIP (e.g "client-id=[threadId]"). > > Best, > Bruno > > On Mon, Jul 1, 2019 at 6:28 PM Boyang Chen > wrote: > > > >

Re: [DISCUSS] KIP-444: Augment Metrics for Kafka Streams

Hello Bruno, Thanks for the feedbacks, replied inline. On Mon, Jul 1, 2019 at 7:08 AM Bruno Cadonna wrote: > Hi Guozhang, > > Thank you for the KIP. > > 1) As far as I understand, the StreamsMetrics interface is there for > user-defined processors. Would it make sense to also add a method to >

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

See Changes: [bbejeck] MINOR: improve error message for incorrect window-serde initialization -- [...truncated 8.73 MB...] kafka.server.ListOffsetsRequestTest > testLis

[jira] [Created] (KAFKA-8684) Create a test of consumer group behavior that tests old clients and new servers

Colin P. McCabe created KAFKA-8684: -- Summary: Create a test of consumer group behavior that tests old clients and new servers Key: KAFKA-8684 URL: https://issues.apache.org/jira/browse/KAFKA-8684 Pro

[jira] [Created] (KAFKA-8683) Flakey test InternalTopicManagerTest @shouldNotCreateTopicIfExistsWithDifferentPartitions

Boyang Chen created KAFKA-8683: -- Summary: Flakey test InternalTopicManagerTest @shouldNotCreateTopicIfExistsWithDifferentPartitions Key: KAFKA-8683 URL: https://issues.apache.org/jira/browse/KAFKA-8683

[jira] [Created] (KAFKA-8682) Add meter for group rebalance rate

Jason Gustafson created KAFKA-8682: -- Summary: Add meter for group rebalance rate Key: KAFKA-8682 URL: https://issues.apache.org/jira/browse/KAFKA-8682 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-8681) IllegalStateException in GroupMetadataManager during transactional offset commit

Sergey Bobrenok created KAFKA-8681: -- Summary: IllegalStateException in GroupMetadataManager during transactional offset commit Key: KAFKA-8681 URL: https://issues.apache.org/jira/browse/KAFKA-8681 Pr

[jira] [Resolved] (KAFKA-8679) kafka-topics.sh --describe with --zookeeper throws error when there is no topic

[ https://issues.apache.org/jira/browse/KAFKA-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weichu Liu resolved KAFKA-8679. --- Resolution: Duplicate > kafka-topics.sh --describe with --zookeeper throws error when there is no >

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

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