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

See Changes: [github] MINOR: Fix unused arguments used in formatted string and log messages [github] MINOR: Fix typo and rephrase content in ops docs (#8581) -- [...tru

Build failed in Jenkins: kafka-trunk-jdk14 #41

See Changes: [github] MINOR: Fix unused arguments used in formatted string and log messages -- [...truncated 1.52 MB...] org.apache.kafka.connect.transforms.TimestampConve

Jenkins build is back to normal : kafka-2.4-jdk8 #193

See

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

See Changes: [github] KAFKA-9919: Add logging to KafkaBasedLog::readToLogEnd (#8554) -- [...truncated 1.52 MB...] org.apache.kafka.connect.transforms.CastTest > castWho

Build failed in Jenkins: kafka-trunk-jdk14 #40

See Changes: [github] KAFKA-9652: Fix throttle metric in RequestChannel and request log due to [github] MINOR: Fix broken JMX link in docs by adding missing starting double [github] KAFKA-9919: Add logging to K

Re: [DISCUSS] KIP-595: A Raft Protocol for the Metadata Quorum

Hello Leonard, Thanks for your comments, I'm relying in line below: On Wed, Apr 29, 2020 at 1:58 AM Wang (Leonard) Ge wrote: > Hi Kafka developers, > > It's great to see this proposal and it took me some time to finish reading > it. > > And I have the following questions about the Proposal: > >

[jira] [Resolved] (KAFKA-9919) Add logging to KafkaBasedLog

[ https://issues.apache.org/jira/browse/KAFKA-9919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-9919. --- Resolution: Fixed > Add logging to KafkaBasedLog > --

[jira] [Created] (KAFKA-9942) --entity-default flag is not working for alternating configs in AdminClient

Cheng Tan created KAFKA-9942: Summary: --entity-default flag is not working for alternating configs in AdminClient Key: KAFKA-9942 URL: https://issues.apache.org/jira/browse/KAFKA-9942 Project: Kafka

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

See Changes: [github] KAFKA-9922: Update demo instructions in examples README (#8559) [github] KAFKA-9652: Fix throttle metric in RequestChannel and request log due to [github] MINOR: Fix broken JMX link in d

what is recommended indexing rules for ETL in general?

Hello Experts, What kind of indexes are recommended for staging area in ETL flow. For example unique index on natural key columns. I have surrogate key as well in data flowing in from source. Also any suggestion/recommendation for indexing in other layers like dimensional data model layer and typ

Build failed in Jenkins: kafka-2.5-jdk8 #105

See Changes: [vvcephei] MINOR: reuse pseudo-topic in FKJoin (#8296) [vvcephei] KAFKA-9925: decorate pseudo-topics with app id (#8574) [github] [KAFKA-9826] Handle an unaligned first dirty offset during log cleani

[jira] [Resolved] (KAFKA-9932) First LeaderAndIsrRequest can take long due to unnecessary ZK read

[ https://issues.apache.org/jira/browse/KAFKA-9932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-9932. Resolution: Fixed > First LeaderAndIsrRequest can take long due to unnecessary ZK read > --

[jira] [Resolved] (KAFKA-9652) Throttle time metric needs to be updated for KIP-219

[ https://issues.apache.org/jira/browse/KAFKA-9652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-9652. Fix Version/s: 2.6.0 Resolution: Fixed > Throttle time metric needs to be updated for KIP-21

[jira] [Created] (KAFKA-9941) When a record triggers a RetriableException and the retry is processed successfully, its offset does not commit.

jiangchuan created KAFKA-9941: - Summary: When a record triggers a RetriableException and the retry is processed successfully, its offset does not commit. Key: KAFKA-9941 URL: https://issues.apache.org/jira/browse/KAFK

Build failed in Jenkins: kafka-trunk-jdk14 #39

See Changes: [github] KAFKA-9922: Update demo instructions in examples README (#8559) -- [...truncated 1.52 MB...] org.apache.kafka.connect.transforms.SetSchemaMetadataTes

[jira] [Resolved] (KAFKA-9830) DeadLetterQueueReporter leaks KafkaProducer instance

[ https://issues.apache.org/jira/browse/KAFKA-9830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-9830. --- Resolution: Fixed > DeadLetterQueueReporter leaks KafkaProducer instance > --

[jira] [Resolved] (KAFKA-9922) Update examples README

[ https://issues.apache.org/jira/browse/KAFKA-9922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-9922. --- Resolution: Fixed > Update examples README > -- > >

[jira] [Created] (KAFKA-9940) Command "jmh.sh -h " doesn't work

jiamei xie created KAFKA-9940: - Summary: Command "jmh.sh -h " doesn't work Key: KAFKA-9940 URL: https://issues.apache.org/jira/browse/KAFKA-9940 Project: Kafka Issue Type: Bug Component

Jenkins build is back to normal : kafka-trunk-jdk8 #4483

See

Build failed in Jenkins: kafka-trunk-jdk14 #38

See Changes: [github] KAFKA-9830: Implement AutoCloseable in ErrorReporter and subclasses -- [...truncated 1.52 MB...] org.apache.kafka.connect.transforms.TimestampConver

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

See Changes: [github] KAFKA-9830: Implement AutoCloseable in ErrorReporter and subclasses -- [...truncated 1.52 MB...] org.apache.kafka.connect.transforms.FlattenTest >

Build failed in Jenkins: kafka-trunk-jdk14 #37

See Changes: [github] KAFKA-9875: Make integration tests more resilient (#8578) -- [...truncated 1.52 MB...] org.apache.kafka.connect.transforms.TimestampConverterTest >

[jira] [Resolved] (KAFKA-7740) Kafka Admin Client should be able to manage user/client configurations for users and clients

[ https://issues.apache.org/jira/browse/KAFKA-7740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin McCabe resolved KAFKA-7740. - Resolution: Fixed > Kafka Admin Client should be able to manage user/client configurations for >

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

See Changes: [github] KAFKA-9932: Don't load configs from ZK when the log has already been [github] KAFKA-9875: Make integration tests more resilient (#8578) -- [...tru

[jira] [Resolved] (KAFKA-9925) Non-key KTable Joining may result in duplicate schema name in confluence schema registry

[ https://issues.apache.org/jira/browse/KAFKA-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9925. - Resolution: Fixed > Non-key KTable Joining may result in duplicate schema name in confluence > s

[jira] [Resolved] (KAFKA-9875) Flaky Test SuppressionDurabilityIntegrationTest.shouldRecoverBufferAfterShutdown[exactly_once]

[ https://issues.apache.org/jira/browse/KAFKA-9875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9875. - Resolution: Fixed https://github.com/apache/kafka/pull/8578 > Flaky Test > SuppressionDurabilit

Build failed in Jenkins: kafka-trunk-jdk14 #36

See Changes: [github] KAFKA-9925: decorate pseudo-topics with app id (#8574) [github] KAFKA-9932: Don't load configs from ZK when the log has already been -- [...truncate

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

See Changes: [github] KAFKA-9925: decorate pseudo-topics with app id (#8574) -- [...truncated 1.52 MB...] org.apache.kafka.connect.transforms.CastTest > castWholeRecord

[jira] [Created] (KAFKA-9939) Fetch request metrics are updated twice for delayed fetches

Jason Gustafson created KAFKA-9939: -- Summary: Fetch request metrics are updated twice for delayed fetches Key: KAFKA-9939 URL: https://issues.apache.org/jira/browse/KAFKA-9939 Project: Kafka

[jira] [Created] (KAFKA-9938) Fix debug consumer read from follower for older protocol versions

Jason Gustafson created KAFKA-9938: -- Summary: Fix debug consumer read from follower for older protocol versions Key: KAFKA-9938 URL: https://issues.apache.org/jira/browse/KAFKA-9938 Project: Kafka

[jira] [Created] (KAFKA-9937) Unable to start Kafka broker using python script

Ravi created KAFKA-9937: --- Summary: Unable to start Kafka broker using python script Key: KAFKA-9937 URL: https://issues.apache.org/jira/browse/KAFKA-9937 Project: Kafka Issue Type: Bug Compon

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

See Changes: [github] KAFKA-9832: fix attempt to commit non-running tasks (#8580) -- [...truncated 3.06 MB...] org.apache.kafka.streams.test.ConsumerRecordFactoryTest >

Re: [DISCUSS] KIP-590: Redirect Zookeeper Mutation Protocols to The Controller

Hi Boyang, Thanks for the update. In the EnvelopeRequest handling section of the KIP it might be worth saying explicitly that authorization of the request will happen as normal. Otherwise what you're proposing makes sense to me. Thanks again, Tom On Wed, Apr 29, 2020 at 5:27 PM Boyang Chen w

[jira] [Created] (KAFKA-9936) kafka-streams 2.5.0 missing dependency?

SledgeHammer created KAFKA-9936: --- Summary: kafka-streams 2.5.0 missing dependency? Key: KAFKA-9936 URL: https://issues.apache.org/jira/browse/KAFKA-9936 Project: Kafka Issue Type: Bug

Re: [DISCUSS] KIP-590: Redirect Zookeeper Mutation Protocols to The Controller

Thanks for the proposed idea Sonke. I reviewed it and had some offline discussion with Colin, Rajini and Mathew. We do need to add serializability to the PrincipalBuilder interface, but we should not make any default implementation which could go wrong and messy up with the security in a productio

Re: [DISCUSS] KIP-589 Add API to Update Replica State in Controller

Hi David, Thanks for the KIP! In the rejecting the alternative of having an RPC for log dir failures you say: It was also rejected to prevent "leaking" the notion of a log dir to the > public API. > I'm not quite sure I follow that argument, since we already have RPCs for changing replica log d

Build failed in Jenkins: kafka-trunk-jdk14 #35

See Changes: [github] KAFKA-9832: fix attempt to commit non-running tasks (#8580) -- [...truncated 1.52 MB...] org.apache.kafka.connect.transforms.TimestampConverterTest

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

See Changes: [github] KAFKA-9832: fix attempt to commit non-running tasks (#8580) -- [...truncated 1.52 MB...] org.apache.kafka.connect.transforms.TimestampConverterTest

Re: [DISCUSS] KIP-595: A Raft Protocol for the Metadata Quorum

Hi Kafka developers, It's great to see this proposal and it took me some time to finish reading it. And I have the following questions about the Proposal: - How do we plan to test this design to ensure its correctness? Or more broadly, how do we ensure that our new ‘pull’ based model is fu

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

See Changes: [github] KAFKA-9127: don't create StreamThreads for global-only topology (#8540) -- [...truncated 3.07 MB...] org.apache.kafka.streams.TopologyTestDriverTest

Build failed in Jenkins: kafka-2.5-jdk8 #104

See Changes: [vvcephei] KAFKA-9127: don't create StreamThreads for global-only topology (#8540) -- [...truncated 2.93 MB...] org.apache.kafka.streams.MockProcessorContextTe

[jira] [Created] (KAFKA-9935) Kafka not releasing member from Consumer Group

Steve Kecskes created KAFKA-9935: Summary: Kafka not releasing member from Consumer Group Key: KAFKA-9935 URL: https://issues.apache.org/jira/browse/KAFKA-9935 Project: Kafka Issue Type: Bug