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

See Changes: [jason] KAFKA-8365; Consumer and protocol support for follower fetching (#6731) -- [...truncated 2.10 MB...] org.apache.kafka.streams.test.OutputVerifierTest

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

See Changes: [jason] KAFKA-8365; Consumer and protocol support for follower fetching (#6731) -- Started by an SCM change [EnvInject] - Loading node environment variables.

[jira] [Resolved] (KAFKA-8365) Protocol and consumer support for follower fetching

[ https://issues.apache.org/jira/browse/KAFKA-8365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8365. Resolution: Fixed > Protocol and consumer support for follower fetching > -

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

See Changes: [bbejeck] KAFKA-6455: Improve DSL operator timestamp semantics (#6725) [cshapi] MINOR: Remove spammy log message during topic deletion -- [...truncated 2.48

Re: Unable to assign any tickets from JIRA

Hello Guozhang, Thanks for getting back to me. I haven't created my apache id yet. I have started the process for that today. I will share with you as soon as I get it. Best, Ishak On Fri, 17 May 2019, 20:16 Guozhang Wang, wrote: > Hello Ishak, > > You'd need to be added to the contributor lis

[jira] [Created] (KAFKA-8389) Duplicated MockProcessorSupplier / MockProcessor in TopologyTestDriverTest

Guozhang Wang created KAFKA-8389: Summary: Duplicated MockProcessorSupplier / MockProcessor in TopologyTestDriverTest Key: KAFKA-8389 URL: https://issues.apache.org/jira/browse/KAFKA-8389 Project: Kaf

[jira] [Created] (KAFKA-8388) Add methods to query for entries in KTable using timestamp

Richard Yu created KAFKA-8388: - Summary: Add methods to query for entries in KTable using timestamp Key: KAFKA-8388 URL: https://issues.apache.org/jira/browse/KAFKA-8388 Project: Kafka Issue Type

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

See Changes: [github] MINOR: Add select changes from 3rd KIP-307 PR for incrementing name [jason] KAFKA-8346; Improve replica fetcher behavior for handling partition [bbejeck] KAFKA-3522: TopologyTestDriver sho

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

See

Re: [kafka-clients] Re: [VOTE] 2.2.1 RC1

Thanks Ismael, and no worries. I'll look forward to hearing some feedback next week. --Vahid On Fri, May 17, 2019 at 12:41 AM Ismael Juma wrote: > Sorry for the delay Vahid. I suspect votes are more likely next week, > after the feature freeze. > > Ismael > > On Thu, May 16, 2019 at 9:45 PM Vah

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

Actually I wonder if it might be useful to users to be able to break up the cache hit stats by type? Some people may choose to store index and filter blocks alongside data blocks, and it would probably be very helpful for them to know who is making more effective use of the cache in order to tune h

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

See Changes: [bbejeck] KAFKA-6455: Improve DSL operator timestamp semantics (#6725) [cshapi] MINOR: Remove spammy log message during topic deletion -- Started by an SCM c

[jira] [Created] (KAFKA-8387) Add `Fenced` state to AbstractCoordinator

Boyang Chen created KAFKA-8387: -- Summary: Add `Fenced` state to AbstractCoordinator Key: KAFKA-8387 URL: https://issues.apache.org/jira/browse/KAFKA-8387 Project: Kafka Issue Type: Improvement

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

Hey Bruno! This all looks pretty good to me, but one suggestion I have is to supplement each of the metrics with some info on how the user can control them. In other words, which options could/should they set in RocksDBConfigSetter should they discover a particular bottleneck? I don't think this

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

See Changes: [bbejeck] KAFKA-8215: Upgrade Rocks to v5.18.3 (#6743) -- [...truncated 3.31 MB...] org.apache.kafka.connect.converters.ByteArrayConverterTest > testToConnect

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

See Changes: [jason] KAFKA-8346; Improve replica fetcher behavior for handling partition [bbejeck] KAFKA-3522: TopologyTestDriver should only return custom stores via --

[jira] [Created] (KAFKA-8386) Use COORDINATOR_NOT_AVAILABLE to replace UNKNOWN_MEMBER_ID when the group is not available

Boyang Chen created KAFKA-8386: -- Summary: Use COORDINATOR_NOT_AVAILABLE to replace UNKNOWN_MEMBER_ID when the group is not available Key: KAFKA-8386 URL: https://issues.apache.org/jira/browse/KAFKA-8386

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

See Changes: [github] MINOR: Add select changes from 3rd KIP-307 PR for incrementing name -- Started by an SCM change [EnvInject] - Loading node environment variables. Bui

2.3 release feature freeze today

Hi all, As discussed earlier, the Kafka 2.3 feature freeze is today. This is the last day for getting in new features or major changes to the release. If your major feature didn't get in, don't feel bad-- there will be another release soon after this one! We will be cutting the 2.3 release b

[jira] [Created] (KAFKA-8385) Fix leader election RPC for all partition so that only partition that had elections are returned

Jose Armando Garcia Sancio created KAFKA-8385: - Summary: Fix leader election RPC for all partition so that only partition that had elections are returned Key: KAFKA-8385 URL: https://issues.apache.org/

[jira] [Created] (KAFKA-8384) Write integration tests for leader election command

Jose Armando Garcia Sancio created KAFKA-8384: - Summary: Write integration tests for leader election command Key: KAFKA-8384 URL: https://issues.apache.org/jira/browse/KAFKA-8384 Project: K

[jira] [Created] (KAFKA-8383) Write integration test for electLeaders

Jose Armando Garcia Sancio created KAFKA-8383: - Summary: Write integration test for electLeaders Key: KAFKA-8383 URL: https://issues.apache.org/jira/browse/KAFKA-8383 Project: Kafka

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

See Changes: [github] MINOR: Fix race condition in Streams tests (#6748) -- [...truncated 2.45 MB...] org.apache.kafka.connect.transforms.SetSchemaMetadataTest > updateS

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

Hi all, this KIP describes the extension of the Kafka Streams' metrics to include RocksDB's internal statistics. Please have a look at it and let me know what you think. Since I am not a RocksDB expert, I am thankful for any additional pair of eyes that evaluates this KIP. https://cwiki.apache.o

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

See Changes: [bbejeck] KAFKA-8215: Upgrade Rocks to v5.18.3 (#6743) -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H32

Re: [VOTE] KIP-369 Alternative Partitioner to Support "Always Round-Robin" Selection

Apologies for the delay. As per the original thread, there have been 3 binding votes. I will be closing this and update the confluence page with the results. Also, I will be submitting the PR soon. Regards, On Fri, 5 Apr 2019 at 00:18, M. Manna wrote: > Thanks Harsha. > > As per your comments,

[jira] [Resolved] (KAFKA-8215) Limit memory usage of RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-8215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8215. Resolution: Fixed > Limit memory usage of RocksDB > - >

[jira] [Resolved] (KAFKA-8354) Replace SyncGroup request/response with automated protocol

[ https://issues.apache.org/jira/browse/KAFKA-8354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8354. Resolution: Fixed > Replace SyncGroup request/response with automated protocol > --

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

See Changes: [jason] MINOR: Add test for ConsumerNetworkClient.trySend (#6739) -- [...truncated 2.44 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shouldFail

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

See Changes: [github] MINOR: Fix race condition in Streams tests (#6748) -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on

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

See Changes: [github] KAFKA-8379; Fix KafkaAdminClientTest.testUnreachableBootstrapServer -- [...truncated 2.50 MB...] org.apache.kafka.connect.converters.ByteArrayConvert

[jira] [Created] (KAFKA-8382) Add TimestampedSessionStore

Matthias J. Sax created KAFKA-8382: -- Summary: Add TimestampedSessionStore Key: KAFKA-8382 URL: https://issues.apache.org/jira/browse/KAFKA-8382 Project: Kafka Issue Type: New Feature

[jira] [Created] (KAFKA-8381) SSL factory for inter-broker listener is broken

Rajini Sivaram created KAFKA-8381: - Summary: SSL factory for inter-broker listener is broken Key: KAFKA-8381 URL: https://issues.apache.org/jira/browse/KAFKA-8381 Project: Kafka Issue Type: B

[jira] [Resolved] (KAFKA-8324) User constructed RocksObjects leak memory

[ https://issues.apache.org/jira/browse/KAFKA-8324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8324. Resolution: Fixed Fix Version/s: 2.3.0 > User constructed RocksObjects leak memory >

[jira] [Resolved] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7190. -- Resolution: Fixed Fix Version/s: 2.3.0 > Under low traffic conditions purging repartitio

[jira] [Resolved] (KAFKA-8034) Replace DeleteTopics request/response with automated protocol

[ https://issues.apache.org/jira/browse/KAFKA-8034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-8034. --- Resolution: Fixed > Replace DeleteTopics request/response with automated protocol > -

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

See Changes: [jason] MINOR: Add test for ConsumerNetworkClient.trySend (#6739) -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remot

[jira] [Resolved] (KAFKA-8379) Flaky test KafkaAdminClientTest.testUnreachableBootstrapServer

[ https://issues.apache.org/jira/browse/KAFKA-8379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-8379. --- Resolution: Fixed Reviewer: Ismael Juma > Flaky test KafkaAdminClientTest.testUnreachab

[jira] [Created] (KAFKA-8380) I can not create a topic, immediately write to it and then read.

Darya Merkureva created KAFKA-8380: -- Summary: I can not create a topic, immediately write to it and then read. Key: KAFKA-8380 URL: https://issues.apache.org/jira/browse/KAFKA-8380 Project: Kafka

Re: Unable to assign any tickets from JIRA

Hello Ishak, You'd need to be added to the contributor list first to get assigned to JIRAs. I can help with that. What's your apache id? Guozhang On Fri, May 17, 2019 at 6:11 AM ishak syed wrote: > Hello, > > Hope you are having a great day. I am trying to assign myself a ticket, but > unfo

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

See Changes: [github] KAFKA-8379; Fix KafkaAdminClientTest.testUnreachableBootstrapServer -- Started by an SCM change [EnvInject] - Loading node environment variables. Bui

Unable to assign any tickets from JIRA

Hello, Hope you are having a great day. I am trying to assign myself a ticket, but unfortunately I am unable to do so. I am pretty sure, my email Id is not available in the contributors list. Can anyone help me out with this issue please? Best, Ishak

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

See Changes: [ismael] KAFKA-8265: Initial implementation for ConnectorClientConfigPolicy to -- [...truncated 2.46 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

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

See Changes: [ismael] KAFKA-8265: Initial implementation for ConnectorClientConfigPolicy to -- Started by an SCM change [EnvInject] - Loading node environment variables. B

[jira] [Created] (KAFKA-8379) Flaky test KafkaAdminClientTest.testUnreachableBootstrapServer

Rajini Sivaram created KAFKA-8379: - Summary: Flaky test KafkaAdminClientTest.testUnreachableBootstrapServer Key: KAFKA-8379 URL: https://issues.apache.org/jira/browse/KAFKA-8379 Project: Kafka

[jira] [Created] (KAFKA-8378) kafka start error when topic data error

ulysses you created KAFKA-8378: -- Summary: kafka start error when topic data error Key: KAFKA-8378 URL: https://issues.apache.org/jira/browse/KAFKA-8378 Project: Kafka Issue Type: Improvement

Re: [VOTE] 2.2.1 RC1

Sorry for the delay Vahid. I suspect votes are more likely next week, after the feature freeze. Ismael On Thu, May 16, 2019 at 9:45 PM Vahid Hashemian wrote: > Since there is no vote on this RC yet, I'll extend the deadline to Monday, > May 20, at 9:00 am. > > Thanks in advance for checking / t

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

See Changes: [rhauch] KAFKA-5505: Incremental cooperative rebalancing in Connect (KIP-415) -- [...truncated 2.44 MB...] org.apache.kafka.connect.file.FileStreamSourceConne