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

See

[jira] [Created] (KAFKA-10842) Refactor raft outbound request channel

Jason Gustafson created KAFKA-10842: --- Summary: Refactor raft outbound request channel Key: KAFKA-10842 URL: https://issues.apache.org/jira/browse/KAFKA-10842 Project: Kafka Issue Type: Sub-

[jira] [Created] (KAFKA-10841) LogReadResult should be able to converted to FetchPartitionData

Chia-Ping Tsai created KAFKA-10841: -- Summary: LogReadResult should be able to converted to FetchPartitionData Key: KAFKA-10841 URL: https://issues.apache.org/jira/browse/KAFKA-10841 Project: Kafka

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

See Changes: [github] KAFKA-10017: fix flaky EOS-beta upgrade test (#9688) [github] MINOR: Update jmh to 1.27 for async profiler support (#9129) -- [...trunc

[jira] [Resolved] (KAFKA-9786) fix flaky MetricsTest.testGeneralBrokerTopicMetricsAreGreedilyRegistered

[ https://issues.apache.org/jira/browse/KAFKA-9786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-9786. --- Resolution: Won't Fix > fix flaky MetricsTest.testGeneralBrokerTopicMetricsAreGreedilyRegiste

[jira] [Resolved] (KAFKA-10463) the necessary utilities in Dockerfile should include git

[ https://issues.apache.org/jira/browse/KAFKA-10463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-10463. Fix Version/s: 2.7.0 Resolution: Fixed > the necessary utilities in Dockerfile shou

[jira] [Resolved] (KAFKA-7036) Complete the docs of KafkaConsumer#poll

[ https://issues.apache.org/jira/browse/KAFKA-7036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-7036. --- Resolution: Won't Fix > Complete the docs of KafkaConsumer#poll > ---

Re: Request to be added as a contributor in Kafka JIRA board

Thanks for your interest Daniel. Added. -Konstantine On Thu, Dec 10, 2020 at 2:34 PM Daniel Osvath wrote: > Hi, > > Please add me as a contributor to the Kafka JIRA board and Confluence > Wiki. My JIRA ID is dosvath. My Confluence ID is dosvath. > > Thanks, > > Daniel > > -

Build failed in Jenkins: Kafka » kafka-2.6-jdk8 #60

See Changes: -- [...truncated 3.17 MB...] org.apache.kafka.streams.TopologyTestDriverTest > shouldProcessRecordForTopic[Eos enabled = false] STARTED org.apache.kafka.streams

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

See

[jira] [Created] (KAFKA-10840) Need way to catch auth issues in poll method

Devin G. Bost created KAFKA-10840: - Summary: Need way to catch auth issues in poll method Key: KAFKA-10840 URL: https://issues.apache.org/jira/browse/KAFKA-10840 Project: Kafka Issue Type: Im

Request to be added as a contributor in Kafka JIRA board

Hi, Please add me as a contributor to the Kafka JIRA board and Confluence Wiki. My JIRA ID is dosvath. My Confluence ID is dosvath. Thanks, Daniel - Daniel Osvath SWE @ Connect Team Confluent Mountain View, CA -

[VOTE] 2.7.0 RC5

Hello Kafka users, developers and client-developers, This is the sixth candidate for release of Apache Kafka 2.7.0. * Configurable TCP connection timeout and improve the initial metadata fetch * Enforce broker-wide and per-listener connection creation rate (KIP-612, part 1) * Throttle Create Topi

Build failed in Jenkins: Kafka » kafka-2.7-jdk8 #76

See Changes: [github] throw corresponding invalid producer epoch (#9700) (#9723) -- [...truncated 6.87 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

[jira] [Created] (KAFKA-10839) Improve consumer group coordinator unavailable message

Lucas Bradstreet created KAFKA-10839: Summary: Improve consumer group coordinator unavailable message Key: KAFKA-10839 URL: https://issues.apache.org/jira/browse/KAFKA-10839 Project: Kafka

[jira] [Created] (KAFKA-10838) Make member fields final if applicable in Connect

Konstantine Karantasis created KAFKA-10838: -- Summary: Make member fields final if applicable in Connect Key: KAFKA-10838 URL: https://issues.apache.org/jira/browse/KAFKA-10838 Project: Kafka

[jira] [Created] (KAFKA-10836) Use type inference and cleanup generic type declarations in Connect

Konstantine Karantasis created KAFKA-10836: -- Summary: Use type inference and cleanup generic type declarations in Connect Key: KAFKA-10836 URL: https://issues.apache.org/jira/browse/KAFKA-10836

[jira] [Created] (KAFKA-10837) Fix javadoc issues and warnings in Connect

Konstantine Karantasis created KAFKA-10837: -- Summary: Fix javadoc issues and warnings in Connect Key: KAFKA-10837 URL: https://issues.apache.org/jira/browse/KAFKA-10837 Project: Kafka

[jira] [Created] (KAFKA-10835) Replace Runnable and Callable overrides with lambdas in Connect

Konstantine Karantasis created KAFKA-10835: -- Summary: Replace Runnable and Callable overrides with lambdas in Connect Key: KAFKA-10835 URL: https://issues.apache.org/jira/browse/KAFKA-10835 P

[jira] [Created] (KAFKA-10834) Remove redundant type casts in Connect

Konstantine Karantasis created KAFKA-10834: -- Summary: Remove redundant type casts in Connect Key: KAFKA-10834 URL: https://issues.apache.org/jira/browse/KAFKA-10834 Project: Kafka Is

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

See

[GitHub] [kafka-site] bbejeck commented on pull request #313: MINOR: remove quickstart-*.html

bbejeck commented on pull request #313: URL: https://github.com/apache/kafka-site/pull/313#issuecomment-742814988 \cc @mimaison This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [kafka-site] bbejeck merged pull request #313: MINOR: remove quickstart-*.html

bbejeck merged pull request #313: URL: https://github.com/apache/kafka-site/pull/313 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

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

See Changes: [github] KAFKA-10677; Complete fetches in purgatory immediately after resigning (#9639) -- [...truncated 3.49 MB...] org.apache.kafka.streams.

Build failed in Jenkins: Kafka » kafka-2.6-jdk8 #59

See Changes: [Mickael Maison] MINOR: Do not print log4j for memberId required (#9667) -- [...truncated 3.17 MB...] org.apache.kafka.streams.TestTopicsTest > test

Re: Request to be added as a contributor in Kafka JIRA board

Added to both. Thanks for joining Lev! -Konstantine On Thu, Dec 10, 2020 at 11:57 AM Lev Zemlyanov wrote: > Hi, > > Please add me as a contributor in Kafka JIRA board and Confluence Wiki. My > JIRA Id is levzemlyanov. My Confluence ID is lev. > > Thanks, Lev > > ---

Request to be added as a contributor in Kafka JIRA board

Hi, Please add me as a contributor in Kafka JIRA board and Confluence Wiki. My JIRA Id is levzemlyanov. My Confluence ID is lev. Thanks, Lev - Lev Zemlyanov SWE @ Connect Team Confluent Mountain View, CA -

Re: [DISCUSS] KIP-687: Automatic Reloading of Security Store

After some offline discussions, we believe that it's the right direction to go by doing a hybrid approach which includes both file-watch trigger and interval based reloading. The former guarantees a swift change in 99% time, while the latter provides a time-based guarantee in the worst case when th

Re: [DISCUSS] KIP-698: Add Explicit User Initialization of Broker-side State to Kafka Streams

Hey John, I think we should avoid logging a warning that implies we've committed to changing a default unless we've absolutely committed to it, which it sounds like we have not (fwiw I'm also on the fence, but leaning towards leaving it automatic -- just think of how many people already forget to

Re: [VOTE] 2.6.1 RC2

Hi, I'm including the fix for https://issues.apache.org/jira/browse/KAFKA-10802 in 2.6.1, so closing this vote. I'll start a new vote once I've built RC3 Thanks On Thu, Dec 3, 2020 at 10:07 AM Mickael Maison wrote: > > Thanks for the report Gary. > > Guozhang, I've opened > https://issues.apach

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

See Changes: [github] KAFKA-10748: Add IP connection rate throttling metric (KIP-612) (#9685) -- [...truncated 6.99 MB...] org.apache.kafka.streams.TopologyT

[jira] [Resolved] (KAFKA-10802) Spurious log message when starting consumers

[ https://issues.apache.org/jira/browse/KAFKA-10802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-10802. Fix Version/s: 2.8.0 2.6.1 Resolution: Fixed > Spurious log mess

Re: [VOTE] KIP-696: Update Streams FSM to clarify ERROR state meaning

KIP looks good to me, thanks Walker! +1 (binding) -Sophie On Thu, Dec 10, 2020 at 1:53 AM Bruno Cadonna wrote: > Thanks, Walker! > > +1 (non-binding) > > Best, > Bruno > > On 09.12.20 20:07, Leah Thomas wrote: > > Looks good, thanks Walker! +1 (non-binding) > > > > Leah > > > > On Wed, Dec 9,

[jira] [Resolved] (KAFKA-9552) Stream should handle OutOfSequence exception thrown from Producer

[ https://issues.apache.org/jira/browse/KAFKA-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9552. Fix Version/s: 2.6.0 Resolution: Fixed > Stream should handle OutOfSequence exceptio

[jira] [Reopened] (KAFKA-9552) Stream should handle OutOfSequence exception thrown from Producer

[ https://issues.apache.org/jira/browse/KAFKA-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-9552: > Stream should handle OutOfSequence exception thrown from Producer > -

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

See

Re: [DISCUSS] KIP-698: Add Explicit User Initialization of Broker-side State to Kafka Streams

Thanks, Bruno, I think my feelings are the same as yours. It seems like either call is just a matter of some forward looking statement in the KIP and maybe a warning log if we're leaning toward changing the default in the future. I'm happy with whatever you prefer. Thanks again, -John On Thu, 2

[jira] [Resolved] (KAFKA-9552) Stream should handle OutOfSequence exception thrown from Producer

[ https://issues.apache.org/jira/browse/KAFKA-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9552. Resolution: Not A Problem > Stream should handle OutOfSequence exception thrown from Producer > ---

[jira] [Resolved] (KAFKA-10677) Complete fetches in purgatory immediately after raft leader resigns

[ https://issues.apache.org/jira/browse/KAFKA-10677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-10677. - Resolution: Fixed > Complete fetches in purgatory immediately after raft leader resigns

[GitHub] [kafka-site] guozhangwang commented on pull request #313: MINOR: remove quickstart-*.html

guozhangwang commented on pull request #313: URL: https://github.com/apache/kafka-site/pull/313#issuecomment-742667050 LGTM. This is an automated message from the Apache Git Service. To respond to the message, please log on t

[jira] [Resolved] (KAFKA-10813) StreamsProducer should catch InvalidProducerEpoch and throw TaskMigrated in all cases

[ https://issues.apache.org/jira/browse/KAFKA-10813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-10813. - Resolution: Fixed > StreamsProducer should catch InvalidProducerEpoch and throw TaskMigrated in

Re: [DISCUSS] KIP-698: Add Explicit User Initialization of Broker-side State to Kafka Streams

Hi John, Thank you for the feedback! I am undecided, because while manual init only makes Kafka Streams safer regarding data loss, it makes first toy apps with Kafka Streams a little bit more complicated. I am a bit more inclined to manual init only, though. Best, Bruno On 10.12.20 15:20,

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

See Changes: [github] KAFKA-10748: Add IP connection rate throttling metric (KIP-612) (#9685) -- [...truncated 3.46 MB...] org.apache.kafka.streams.TopologyTe

Re: [DISCUSS] KIP-698: Add Explicit User Initialization of Broker-side State to Kafka Streams

Hi Bruno, Thanks for the KIP! This seems like a nice data integrity improvement, and the KIP looks good to me. I’m wondering if we should plan to transition to manual init only in the future. I.e. maybe we log a warning, then later on we switch the default config to manual, and then ultimately

Re: [DISCUSS] KIP-690 Add additional configuration to control MirrorMaker 2 internal topics naming convention

Hi Mickael, 1) That's right the interface and default implementation will in mirror-connect 2) Renaming the interface should be fine too especially if you planning to move other functionality related to the creation there, I can edit this if you are okay with that please vote for the KIP here http

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

See Changes: [github] KAFKA-10747: Extend DescribeClientQuotas and AlterClientQuotas APIs to support IP connection rate quota (KIP-612) (#9628) -- [...trunc

Re: [DISCUSS] KIP-690 Add additional configuration to control MirrorMaker 2 internal topics naming convention

Hi Omnia, Thank you for the reply, it makes sense. A couple more comments: 1) I'm assuming the new interface and default implementation will be in the mirror-client project? as the names of some of these topics are needed by RemoteClusterUtils on the client-side. 2) I'm about to open a KIP to s

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

See Changes: [github] KAFKA-10747: Extend DescribeClientQuotas and AlterClientQuotas APIs to support IP connection rate quota (KIP-612) (#9628) -- [...trunca

[jira] [Resolved] (KAFKA-10748) Add IP connection rate throttling metric

[ https://issues.apache.org/jira/browse/KAFKA-10748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-10748. - Fix Version/s: 2.8.0 Resolution: Fixed > Add IP connection rate throttling metric > -

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

See

[jira] [Created] (KAFKA-10833) KIP-661: Expose task configurations in Connect REST API

Mickael Maison created KAFKA-10833: -- Summary: KIP-661: Expose task configurations in Connect REST API Key: KAFKA-10833 URL: https://issues.apache.org/jira/browse/KAFKA-10833 Project: Kafka I

Re: [VOTE] KIP-661: Expose task configurations in Connect REST API

I'm +1 (binding) too The vote passes. Here is the summary: +3 binding votes: Gwen, Bill, Mickael +3 non-binding votes: Brandon, Ning, Tom I'll get a PR ready, thanks! On Thu, Dec 3, 2020 at 10:26 PM Bill Bejeck wrote: > > Hi Mickael, > > This KIP looks like it will be useful. > > +1 (binding) >

[DISCUSS] KIP-698: Add Explicit User Initialization of Broker-side State to Kafka Streams

Hi, I'd like to start the discussion on KIP-698 that proposes an explicit user initialization of broker-side state for Kafka Streams instead of letting Kafka Streams setting up the broker-side state automatically during rebalance. Such an explicit initialization avoids possible data loss issu

[jira] [Resolved] (KAFKA-10772) java.lang.IllegalStateException: There are insufficient bytes available to read assignment from the sync-group response (actual byte size 0)

[ https://issues.apache.org/jira/browse/KAFKA-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-10772. --- Resolution: Duplicate > java.lang.IllegalStateException: There are insufficient bytes availa

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

See Changes: [github] throw corresponding invalid producer epoch (#9700) -- [...truncated 3.46 MB...] org.apache.kafka.streams.TopologyTestDriverTest > shou

Re: [VOTE] KIP-696: Update Streams FSM to clarify ERROR state meaning

Thanks, Walker! +1 (non-binding) Best, Bruno On 09.12.20 20:07, Leah Thomas wrote: Looks good, thanks Walker! +1 (non-binding) Leah On Wed, Dec 9, 2020 at 1:04 PM John Roesler wrote: Thanks, Walker! I'm also +1 (binding) -John On Wed, 2020-12-09 at 11:03 -0800, Guozhang Wang wrote: +1

Re: [DISCUSS] KIP-696: Update Streams FSM to clarify ERROR state meaning

Thanks for the KIP, Walker! The KIP looks good to me. I have just a minor comment about the KIP document. You talk about SHUTDOWN_CLIENT in the KIP, but never explain that it is a possible action that can be taken in the Streams uncaught exception handler. Could you please clarify that? Be

[jira] [Resolved] (KAFKA-10747) Implement ClientQuota APIs for altering and describing IP entity quotas

[ https://issues.apache.org/jira/browse/KAFKA-10747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-10747. - Fix Version/s: 2.8.0 Resolution: Fixed > Implement ClientQuota APIs for altering and desc

Re: [DISCUSS] KIP-690: Add additional configuration to control MirrorMaker 2 internal topics naming convention

Thanks, Ryanne for feedback. Could you please vote on the voting thread https://www.mail-archive.com/dev@kafka.apache.org/msg113575.html thanks Omnia On Fri, Dec 4, 2020 at 4:53 PM Ryanne Dolan wrote: > Thanks Omnia, this looks great. I like the approach of introducing another > policy class. >

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

See Changes: [github] throw corresponding invalid producer epoch (#9700) -- [...truncated 3.49 MB...] org.apache.kafka.streams.test.MockProcessorContextStat