[jira] [Resolved] (KAFKA-10604) The StreamsConfig.STATE_DIR_CONFIG's default value does not reflect the JVM parameter or OS-specific settings

[ https://issues.apache.org/jira/browse/KAFKA-10604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10604. - Fix Version/s: 2.8.0 Resolution: Fixed Thanks for reporting the issue and the PR!

[jira] [Created] (KAFKA-12267) Implement DescribeTransactions API

Jason Gustafson created KAFKA-12267: --- Summary: Implement DescribeTransactions API Key: KAFKA-12267 URL: https://issues.apache.org/jira/browse/KAFKA-12267 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-12238) Implement DescribeProducers API

[ https://issues.apache.org/jira/browse/KAFKA-12238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-12238. - Resolution: Fixed > Implement DescribeProducers API > --- >

Re: [DISCUSS] KIP-708: Rack aware Kafka Streams with pluggable StandbyTask assignor

Hello Levani, Thanks for the reply. 1. Interesting; why did you change your mind? I have a gut feeling that we can achieve pretty much any rack awareness need that people have by using purely config, which is obviously much easier to use. But if you had a case in mind where this wouldn’t work

[jira] [Created] (KAFKA-12266) KIP-500: Add the Broker Lifecycle Manager

Alok Nikhil created KAFKA-12266: --- Summary: KIP-500: Add the Broker Lifecycle Manager Key: KAFKA-12266 URL: https://issues.apache.org/jira/browse/KAFKA-12266 Project: Kafka Issue Type: Task

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

See Changes: [github] KAFKA-10366 & KAFKA-9649: Implement KIP-659 to allow TimeWindowedDeserializer and TimeWindowedSerde to handle window size (#9253) -- [.

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

See Changes: [github] MINOR: Factor out controller node provider `BrokerToControllerChannelManager` (#10015) -- [...truncated 7.12 MB...] SslConsumerTest >

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

See Changes: [github] MINOR: Factor out controller node provider `BrokerToControllerChannelManager` (#10015) [github] KAFKA-10366 & KAFKA-9649: Implement KIP-659 to allow TimeWindowedDeserializer

[jira] [Created] (KAFKA-12265) Move the BatchAccumulator in KafkaRaftClient to LeaderState

Jose Armando Garcia Sancio created KAFKA-12265: -- Summary: Move the BatchAccumulator in KafkaRaftClient to LeaderState Key: KAFKA-12265 URL: https://issues.apache.org/jira/browse/KAFKA-12265

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

See Changes: [github] MINOR: Factor out controller node provider `BrokerToControllerChannelManager` (#10015) -- [...truncated 3.57 MB...] LogValidatorTest >

[jira] [Reopened] (KAFKA-10895) Basic auth extension's JAAS config can be corrupted by other plugins

[ https://issues.apache.org/jira/browse/KAFKA-10895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reopened KAFKA-10895: --- > Basic auth extension's JAAS config can be corrupted by other plugins > ---

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

See Changes: [github] KAFKA-12245; Fix flaky `FetcherTest.testEarlierOffsetResetArrivesLate` (#10006) -- [...truncated 7.15 MB...] TimerTest > testTaskExpi

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

See Changes: [github] KAFKA-12245; Fix flaky `FetcherTest.testEarlierOffsetResetArrivesLate` (#10006) -- [...truncated 3.56 MB...] ApiVersionTest > testApiVe

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

See Changes: [github] KAFKA-12245; Fix flaky `FetcherTest.testEarlierOffsetResetArrivesLate` (#10006) -- [...truncated 3.58 MB...] AuthorizerIntegrationTes

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

See Changes: [github] KAFKA-10636; Bypass log validation and offset assignment for writes from the raft leader (#9739) [github] KAFKA-7940: Fix flaky test case in `CustomQuotaCallbackTest` (#9777)

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

See

Re: [DISCUSS] KIP-618: Atomic commit of source connector records and offsets

Hi Chris, If we add the new `fenceProducers` admin API, can we return the information from the `InitProducerId` response (i.e. producer id and epoch)? We may not have a use case for it yet, but I don't see any harm exposing it for the future. For example, we could allow this state to be provided t

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

See Changes: [github] KAFKA-10636; Bypass log validation and offset assignment for writes from the raft leader (#9739) [github] KAFKA-7940: Fix flaky test case in `CustomQuotaCallbackTest` (#9777)

[jira] [Resolved] (KAFKA-12245) fix flay org.apache.kafka.clients.consumer.internals.FetcherTest.testEarlierOffsetResetArrivesLate

[ https://issues.apache.org/jira/browse/KAFKA-12245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-12245. - Resolution: Fixed > fix flay > org.apache.kafka.clients.consumer.internals.FetcherTest.

[jira] [Created] (KAFKA-12264) JMH BaseRecordBatchBenchmark ZSTD error

Jeff Kim created KAFKA-12264: Summary: JMH BaseRecordBatchBenchmark ZSTD error Key: KAFKA-12264 URL: https://issues.apache.org/jira/browse/KAFKA-12264 Project: Kafka Issue Type: Bug R

[jira] [Resolved] (KAFKA-10636) Bypass log validation for writes to raft log

[ https://issues.apache.org/jira/browse/KAFKA-10636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-10636. - Resolution: Fixed > Bypass log validation for writes to raft log > -

[jira] [Created] (KAFKA-12263) Improve MockClient RequestMatcher interface

Jason Gustafson created KAFKA-12263: --- Summary: Improve MockClient RequestMatcher interface Key: KAFKA-12263 URL: https://issues.apache.org/jira/browse/KAFKA-12263 Project: Kafka Issue Type:

Re: [DISCUSS] KIP-691: Transactional Producer Exception Handling

Hey Jason and Chia-Ping, looking at the discussion thread for KIP-706, we are still in discussion with the final API version, so I made the decision to decouple the two KIPs so that this one could move forward. To be specific, we are still introducing ProduceFailed error but as a `near-future` imp

[jira] [Reopened] (KAFKA-10340) Source connectors should report error when trying to produce records to non-existent topics instead of hanging forever

[ https://issues.apache.org/jira/browse/KAFKA-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reopened KAFKA-10340: --- Assignee: Chris Egerton (was: Luke Chen) > Source connectors should report error when try

[GitHub] [kafka-site] guozhangwang merged pull request #329: Add docs for RocksDB metrics specified in KIP-607

guozhangwang merged pull request #329: URL: https://github.com/apache/kafka-site/pull/329 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

Re: Kafka Contributors List

Done Thanks for your interest in Apache Kafka On Sun, Jan 31, 2021 at 4:29 PM Neil Fairweather wrote: > > Hi, > > Could I please be added to the Kafka contributor list in JIRA? My username > is neildf > > Thanks! > > Neil

[jira] [Created] (KAFKA-12262) New session keys are never distributed when follower with key becomes leader

Chris Egerton created KAFKA-12262: - Summary: New session keys are never distributed when follower with key becomes leader Key: KAFKA-12262 URL: https://issues.apache.org/jira/browse/KAFKA-12262 Projec

Re: [DISCUSS] KIP-708: Rack aware Kafka Streams with pluggable StandbyTask assignor

Hi John, Thanks a lot for thorough feedback, it’s really valuable. 1. Agree with this. Had the same idea initially. We can set some upper limit in terms of what’s the max number of tags users can set to make sure it’s not overused. By default, we can create standby tasks where tags are differe

[GitHub] [kafka-site] cadonna commented on pull request #329: Add docs for RocksDB metrics specified in KIP-607

cadonna commented on pull request #329: URL: https://github.com/apache/kafka-site/pull/329#issuecomment-770739088 Call for review: @ableegoldman This is an automated message from the Apache Git Service. To respond to the mes

[GitHub] [kafka-site] cadonna opened a new pull request #329: Add docs for RocksDB metrics specified in KIP-607

cadonna opened a new pull request #329: URL: https://github.com/apache/kafka-site/pull/329 This is a backport of PR https://github.com/apache/kafka/pull/9895 to 2.7 since, I missed to add them before 2.7 was released. This i

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

See Changes: [github] MINOR: Reorder modifiers and Replace Map.get with Map.computeIfAbsent (#9991) -- [...truncated 3.32 MB...] PlaintextAdminIntegrationT

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

See Changes: [github] MINOR: fix @link tags in javadoc (#9939) -- [...truncated 7.18 MB...] AuthorizerIntegrationTest > testCommitWithNoGroupAccess() STARTED