Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #241

See Changes: [github] KAFKA-10628: remove all the unnecessary parameters from the tests which are using TopologyTestDriver (#9507) -- [...truncated 3.47 MB.

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #240

See Changes: [github] KAFKA-10545: Create topic IDs in ZooKeeper and Controller (#9473) [github] KAFKA-10500: Allow resizing of StreamThread state store caches (#9572) [github] KAFKA-9274: Handle T

[jira] [Created] (KAFKA-10745) Please let me know how I check the time which Source connector receive the data from source table.

NAYUSIK created KAFKA-10745: --- Summary: Please let me know how I check the time which Source connector receive the data from source table. Key: KAFKA-10745 URL: https://issues.apache.org/jira/browse/KAFKA-10745

Jenkins build is back to normal : Kafka » kafka-trunk-jdk11 #239

See

Jenkins build is back to normal : Kafka » kafka-trunk-jdk15 #263

See

[jira] [Created] (KAFKA-10744) Listener and broker connection rate quota tests should use mock time

David Mao created KAFKA-10744: - Summary: Listener and broker connection rate quota tests should use mock time Key: KAFKA-10744 URL: https://issues.apache.org/jira/browse/KAFKA-10744 Project: Kafka

[jira] [Resolved] (KAFKA-4748) Need a way to shutdown all workers in a Streams application at the same time

[ https://issues.apache.org/jira/browse/KAFKA-4748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-4748. --- Resolution: Fixed > Need a way to shutdown all workers in a Streams applicati

[jira] [Reopened] (KAFKA-10500) Add API to Start and Stop Stream Threads

[ https://issues.apache.org/jira/browse/KAFKA-10500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reopened KAFKA-10500: > Add API to Start and Stop Stream Threads > -

[jira] [Resolved] (KAFKA-6943) Have option to shutdown KS cleanly if any threads crashes, or if all threads crash

[ https://issues.apache.org/jira/browse/KAFKA-6943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-6943. --- Resolution: Fixed > Have option to shutdown KS cleanly if any threads crashes

[jira] [Resolved] (KAFKA-10500) Add API to Start and Stop Stream Threads

[ https://issues.apache.org/jira/browse/KAFKA-10500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10500. - Fix Version/s: 2.8.0 Resolution: Fixed > Add API to Start and Stop Stream Threads

[jira] [Resolved] (KAFKA-10687) Produce request should be bumped for new error code PRODUCE_FENCED

[ https://issues.apache.org/jira/browse/KAFKA-10687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-10687. - Resolution: Fixed Fixed for 2.7 via https://github.com/apache/kafka/pull/9613 > Produce request

[jira] [Resolved] (KAFKA-9628) Replace Produce request/response with automated protocol

[ https://issues.apache.org/jira/browse/KAFKA-9628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9628. Fix Version/s: 2.8.0 Resolution: Fixed > Replace Produce request/response with autom

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #229

See Changes: [github] MINOR: remove "gradle wrapper" from travis.yml (#9610) [github] MINOR: Unifies implementations for commitSync (#6319) -- [...truncated

[jira] [Created] (KAFKA-10743) Fix NumRequestsForwardingToControllerPerSec metric in ForwardingManager

Jason Gustafson created KAFKA-10743: --- Summary: Fix NumRequestsForwardingToControllerPerSec metric in ForwardingManager Key: KAFKA-10743 URL: https://issues.apache.org/jira/browse/KAFKA-10743 Project

[jira] [Created] (KAFKA-10742) Automated protocol should support java.util.Optional

David Jacot created KAFKA-10742: --- Summary: Automated protocol should support java.util.Optional Key: KAFKA-10742 URL: https://issues.apache.org/jira/browse/KAFKA-10742 Project: Kafka Issue Type

[jira] [Created] (KAFKA-10741) Kafka ConsumerProperties.addDeserializerToConfig breaks hirarchical property resolution.

Michael created KAFKA-10741: --- Summary: Kafka ConsumerProperties.addDeserializerToConfig breaks hirarchical property resolution. Key: KAFKA-10741 URL: https://issues.apache.org/jira/browse/KAFKA-10741 Projec

[jira] [Created] (KAFKA-10740) ReplicaFetcherThread should use OffsetForLeaderPartitionResult directly

David Jacot created KAFKA-10740: --- Summary: ReplicaFetcherThread should use OffsetForLeaderPartitionResult directly Key: KAFKA-10740 URL: https://issues.apache.org/jira/browse/KAFKA-10740 Project: Kafka

[jira] [Created] (KAFKA-10739) KafkaApis#handleOffsetForLeaderEpochRequest should use OffsetForLeaderPartition directly

David Jacot created KAFKA-10739: --- Summary: KafkaApis#handleOffsetForLeaderEpochRequest should use OffsetForLeaderPartition directly Key: KAFKA-10739 URL: https://issues.apache.org/jira/browse/KAFKA-10739

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #262

See Changes: [github] MINOR: remove "gradle wrapper" from travis.yml (#9610) [github] MINOR: Unifies implementations for commitSync (#6319) -- [...truncated

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #238

See Changes: [github] MINOR: remove "gradle wrapper" from travis.yml (#9610) [github] MINOR: Unifies implementations for commitSync (#6319) -- [...truncated

[jira] [Created] (KAFKA-10738) kafka version 2.5.0 on Windows Cygwin could not started when using openjdk or corretto 11

Duke Pham created KAFKA-10738: - Summary: kafka version 2.5.0 on Windows Cygwin could not started when using openjdk or corretto 11 Key: KAFKA-10738 URL: https://issues.apache.org/jira/browse/KAFKA-10738 P

Re: Requesting Contributor Permissions

Arun, You're all set now. Thanks for your interest in Apache Kafka -Bill On Wed, Nov 18, 2020 at 12:35 AM Arun Parthiban wrote: > Hi, > > I would like to make contributions to kafka and following the instructions > in https://kafka.apache.org/contributing.html I would like to be added to > th

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #228

See Changes: [github] MINOR: move the test cases which don't need brokers from TopicCommandWithAdminClientTest to TopicCommandTest (#9501) [github] KAFKA-10618: Rename UUID to Uuid and make it more

Jenkins build is back to normal : Kafka » kafka-trunk-jdk11 #237

See

Re: [DISCUSSION] KIP-686: API to ensure Records policy on the broker

Hello, Ismael. Thanks for the feedback. You are right, I read public interfaces definition not carefully :) Updated KIP according to your objection. I propose to expose 2 new public interfaces: ``` package org.apache.kafka.common; public interface Record { long timestamp(); boolean has

Jenkins build is back to normal : Kafka » kafka-trunk-jdk8 #227

See

Jenkins build is back to normal : Kafka » kafka-trunk-jdk15 #260

See

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #236

See Changes: [github] KAFKA-10687: make ProduceRespone only returns INVALID_PRODUCER_EPOCH (#9569) -- [...truncated 6.93 MB...] org.apache.kafka.streams.te