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

See Changes: [github] KAFKA-7652: Part II; Add single-point query for SessionStore and use for -- [...truncated 4.56 MB...] org.apache.kafka.streams.test.OutputVerifierT

Re: [DISCUSS] KIP-416: Notify SourceTask of ACK'd offsets, metadata

As you might expect, I like the overloaded commitRecord() but I think the overloaded method should be called in exactly the same situations as the previous method. When it does not reflect an ACK, the second parameter could be null. The text of the KIP says that the overloaded method is only cal

Re: [DISCUSS] KIP-390: Add producer option to adjust compression level

Mickael, It seems like the majority of the community agrees that the new config scheme proposed by Becket is much better. However, we still need another KIP to support this kind of config; it is different from the case of `listener.security.protocol.map,` which is just a concatenation of available

Quotas in Kafka

Hello, I'm testing the Quotas in Kafka, but the results are not coherent I'm configuring the parameters "producer_byte_rate and consumer_byte_rate" For example: I configured 10 messages with 100 kb "./bin/kafka-producer-perf-test.sh --topic first_topic --num-records 10 --record-size 9 --throu

[jira] [Created] (KAFKA-7886) Some partitions are fully truncated during recovery when log.message.format = 0.10.2 & inter.broker.protocol >= 0.11

Hervé RIVIERE created KAFKA-7886: Summary: Some partitions are fully truncated during recovery when log.message.format = 0.10.2 & inter.broker.protocol >= 0.11 Key: KAFKA-7886 URL: https://issues.apache.org/jira/b

Re: [DISCUSS] KIP-416: Notify SourceTask of ACK'd offsets, metadata

Andrew, I have considered this, but I think passing null for RecordMetadata would be surprising and error prone for anyone implementing SourceTask. I figure the only use-case for overriding this variant (and not the existing one) is to capture the RecordMetadata. If that's the case, every implement

[jira] [Created] (KAFKA-7887) Transaction Producer hanging when commiting/aborting transaction after a broker failure

Cameron created KAFKA-7887: -- Summary: Transaction Producer hanging when commiting/aborting transaction after a broker failure Key: KAFKA-7887 URL: https://issues.apache.org/jira/browse/KAFKA-7887 Project: Ka

[jira] [Resolved] (KAFKA-7887) Transaction Producer hanging when commiting/aborting transaction after a broker failure

[ https://issues.apache.org/jira/browse/KAFKA-7887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cameron resolved KAFKA-7887. Resolution: Duplicate > Transaction Producer hanging when commiting/aborting transaction after a > broker

[jira] [Resolved] (KAFKA-7790) Fix Bugs in Trogdor Task Expiration

[ https://issues.apache.org/jira/browse/KAFKA-7790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-7790. Resolution: Fixed > Fix Bugs in Trogdor Task Expiration > -

[jira] [Resolved] (KAFKA-7792) Trogdor should have an uptime function

[ https://issues.apache.org/jira/browse/KAFKA-7792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-7792. Resolution: Fixed > Trogdor should have an uptime function > --

[jira] [Resolved] (KAFKA-7793) Improve the Trogdor command-line

[ https://issues.apache.org/jira/browse/KAFKA-7793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-7793. Resolution: Fixed > Improve the Trogdor command-line > > >

Re: broken build on windows

Hi Chia-Ping Tsai, Thanks for the patch. :) cheers, Colin On Wed, Jan 30, 2019, at 07:31, Chia-Ping Tsai wrote: > hi folks, > > I love GNU/Linux but it pains me to see broken build on windows. Could > someone take a look at PR: https://github.com/apache/kafka/pull/6208 ? > It enables kafka

[jira] [Created] (KAFKA-7888) kafka cluster not recovering - Shrinking ISR from 14,13 to 13 (kafka.cluster.Partition) continously

Kemal ERDEN created KAFKA-7888: -- Summary: kafka cluster not recovering - Shrinking ISR from 14,13 to 13 (kafka.cluster.Partition) continously Key: KAFKA-7888 URL: https://issues.apache.org/jira/browse/KAFKA-7888

[jira] [Created] (KAFKA-7889) Kafka broker crashes on windows when log compaction is used

huzaifa kagazwala created KAFKA-7889: Summary: Kafka broker crashes on windows when log compaction is used Key: KAFKA-7889 URL: https://issues.apache.org/jira/browse/KAFKA-7889 Project: Kafka

[jira] [Resolved] (KAFKA-7859) Replace LeaveGroup request/response with automated protocol

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

[jira] [Resolved] (KAFKA-7816) Windowed topic should have window size as part of the metadata

[ https://issues.apache.org/jira/browse/KAFKA-7816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-7816. Resolution: Won't Fix Not a real use case > Windowed topic should have window size as part of the

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

See Changes: [colin] KAFKA-7859: Use automatic RPC generation in LeaveGroups (#6188) -- [...truncated 2.28 MB...] org.apache.kafka.connect.transforms.TimestampConverterTe

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

See Changes: [colin] KAFKA-7859: Use automatic RPC generation in LeaveGroups (#6188) [colin] MINOR: fix checkstyle suppressions for generated RPC code to work on -- [...t

[jira] [Created] (KAFKA-7890) Invalidate ClusterConnectionState cache for a broker if the hostname of the broker changes.

Mark Cho created KAFKA-7890: --- Summary: Invalidate ClusterConnectionState cache for a broker if the hostname of the broker changes. Key: KAFKA-7890 URL: https://issues.apache.org/jira/browse/KAFKA-7890 Proje

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

See Changes: [colin] MINOR: fix checkstyle suppressions for generated RPC code to work on -- [...truncated 2.28 MB...] org.apache.kafka.connect.transforms.HoistFieldTest

Re: [DISCUSS] KIP-390: Add producer option to adjust compression level

Hi Dongjin, Thanks for the reply. I agree that implementation wise, it is clearer to add a new "Map" config type. However, practically speaking I don't think this KIP strongly depends on that. As long as we follow the same string format in the configuration for all those map-like configurations, w

[jira] [Reopened] (KAFKA-7799) Fix flaky test RestServerTest.testCORSEnabled

[ https://issues.apache.org/jira/browse/KAFKA-7799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reopened KAFKA-7799: -- This test is failing frequently on Jenkins builds. Reopening. > Fix flaky test RestServerTest.testCORSEnab

Re: [VOTE] KIP-417: Allow JmxTool to connect to a secured RMI port

Hi, +1 (binding). Thanks for the KIP. On Mon, Jan 28, 2019 at 5:37 PM Fangbin Sun wrote: > Hi, All: > I would like to start a vote on KIP-417 which aims at supporting JmxTool > to connect to a secured RMI port. > > > The KIP: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-417%3A+Allo

[jira] [Created] (KAFKA-7891) Reduce time to start kafka server with clean state

Pradeep Bansal created KAFKA-7891: - Summary: Reduce time to start kafka server with clean state Key: KAFKA-7891 URL: https://issues.apache.org/jira/browse/KAFKA-7891 Project: Kafka Issue Typ

[jira] [Created] (KAFKA-7892) kafka broker jvm old increase continually

wangxingmin created KAFKA-7892: -- Summary: kafka broker jvm old increase continually Key: KAFKA-7892 URL: https://issues.apache.org/jira/browse/KAFKA-7892 Project: Kafka Issue Type: Bug