Build failed in Jenkins: kafka-trunk-jdk7 #3268

See Changes: [github] MINOR: fix flaky Streams EOS system test (#4728) -- [...truncated 1.53 MB...] org.apache.kafka.streams.integration.KStreamsFineGrainedAutoResetIntegr

Jenkins build is back to normal : kafka-1.1-jdk7 #88

See

[jira] [Created] (KAFKA-6677) Remove EOS producer config max.in.flight.request.per.connection=1

Matthias J. Sax created KAFKA-6677: -- Summary: Remove EOS producer config max.in.flight.request.per.connection=1 Key: KAFKA-6677 URL: https://issues.apache.org/jira/browse/KAFKA-6677 Project: Kafka

Re: [DISCUSSION] KIP-266: Add TimeoutException to KafkaConsumer#position()

Actually, what I said above is inaccurate. In testSeekAndCommitWithBrokerFailures, TestUtils.waitUntilTrue blocks, not seek. My assumption is that seek did not update correctly. I will be digging further into this. On Sat, Mar 17, 2018 at 4:16 PM, Richard Yu wrote: > One more thing: when looki

Re: [DISCUSSION] KIP-266: Add TimeoutException to KafkaConsumer#position()

One more thing: when looking through tests, I have realized that seek() methods can potentially block indefinitely. As you well know, seek() is called when pollOnce() or position() is active. Thus, if position() blocks indefinitely, then so would seek(). Should bounding seek() also be included in t

[jira] [Created] (KAFKA-6676) System tests do not handle ZK chroot properly with SCRAM

Ewen Cheslack-Postava created KAFKA-6676: Summary: System tests do not handle ZK chroot properly with SCRAM Key: KAFKA-6676 URL: https://issues.apache.org/jira/browse/KAFKA-6676 Project: Kafka

Jenkins build is back to normal : kafka-trunk-jdk7 #3267

See

Re: [DISCUSSION] KIP-266: Add TimeoutException to KafkaConsumer#position()

Thanks for the advice, Jason I have modified KIP-266 to include the java doc for committed() and other blocking methods, and I also mentioned poll() which will also be bounded. Let me know if there is anything else. :) Sincerely, Richard On Sat, Mar 17, 2018 at 12:00 PM, Jason Gustafson wro

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

See Changes: [jason] KAFKA-6530: Use actual first offset of message set when rolling log -- [...truncated 420.93 KB...] kafka.zookeeper.ZooKeeperClientTest > testZNodeChi

Re: [DISCUSSION] KIP-266: Add TimeoutException to KafkaConsumer#position()

Hi Richard, Thanks for the updates. I'm really glad you picked this up. A couple minor comments: 1. Can you list the full set of new APIs explicitly in the KIP? Currently I only see the javadoc for `position()`. 2. We should consider adding `TimeUnit` to the new methods to avoid unit confusion.

Re: [DISCUSS] KIP-211: Revise Expiration Semantics of Consumer Group Offsets

Hey Vahid, Sorry for the delay. I've read through the current KIP and it looks good. I had one minor suggestion: instead of making the timestamp in the group metadata state message specific to the empty state transition (i.e. "empty_state_timestamp"), could we leave it generic and let it indicate

[jira] [Created] (KAFKA-6675) Connect workers should log plugin path and available plugins more clearly

Randall Hauch created KAFKA-6675: Summary: Connect workers should log plugin path and available plugins more clearly Key: KAFKA-6675 URL: https://issues.apache.org/jira/browse/KAFKA-6675 Project: Kafk

[jira] [Resolved] (KAFKA-6674) Kafka start script does not work on ibm jre

[ https://issues.apache.org/jira/browse/KAFKA-6674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamar Thais resolved KAFKA-6674. Resolution: Duplicate Fix Version/s: (was: 1.0.2) Duplicate with https://issues.apache.or

[jira] [Created] (KAFKA-6674) Kafka start script does not work on ibm jre

Tamar Thais created KAFKA-6674: -- Summary: Kafka start script does not work on ibm jre Key: KAFKA-6674 URL: https://issues.apache.org/jira/browse/KAFKA-6674 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-6530) Use actual first offset of messages when rolling log segment for magic v2

[ https://issues.apache.org/jira/browse/KAFKA-6530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6530. Resolution: Fixed Fix Version/s: 1.2.0 > Use actual first offset of messages when rol

[jira] [Resolved] (KAFKA-6338) java.lang.NoClassDefFoundError: org/apache/kafka/common/network/LoginType

[ https://issues.apache.org/jira/browse/KAFKA-6338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6338. -- Resolution: Not A Problem Closing this  in-favor of RANGER-1964 > java.lang.NoClassDefFoundError: org/a

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

See Changes: [github] KAFKA-6672; ConfigCommand should create config change parent path if [jason] MINOR: Remove unnecessary null checks (#4708) -- [...truncated 1.88 MB.

[jira] [Resolved] (KAFKA-6596) Why we can not see any consumer offset produce rate in kafka manager

[ https://issues.apache.org/jira/browse/KAFKA-6596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6596. -- Resolution: Not A Problem I suggest you to reach out kafka-manager mailing list/github community for any

[jira] [Resolved] (KAFKA-5187) producer.close() times out at 30 seconds

[ https://issues.apache.org/jira/browse/KAFKA-5187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5187. -- Resolution: Not A Problem Please reopen if the issue still exists. > producer.close() times out at 30 s

[jira] [Resolved] (KAFKA-4782) change chroot for a kafka instance

[ https://issues.apache.org/jira/browse/KAFKA-4782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4782. -- Resolution: Not A Problem > change chroot for a kafka instance > -- > >

Re: [DISCUSS] KIP-271 Add NetworkClient redirector

Hi, Rajini, Thank you! This is really great advice, I will review that and test it out in our scenarios. Do you know any limitations when advertised.listeners may not work? Having the option to redirecting broker calls on client side is still valuable for kafka server setup that cannot have adver

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

See Changes: [github] KAFKA-6454: Allow timestamp manipulation in Processor API (#4519) [jason] KAFKA-6658; Fix RoundTripWorkload and make k/v generation configurable --

Build failed in Jenkins: kafka-trunk-jdk7 #3266

See Changes: [jason] MINOR: Remove unnecessary null checks (#4708) -- [...truncated 416.32 KB...] kafka.server.epoch.LeaderEpochFileCacheTest > shouldPersistEpochsBetwee

Jenkins build is back to normal : kafka-trunk-jdk9 #486

See

[jira] [Resolved] (KAFKA-3553) Issue with getting data of next offset after restarting the consumer and producer is always running

[ https://issues.apache.org/jira/browse/KAFKA-3553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3553. -- Resolution: Auto Closed {color:#00}Closing inactive issue. Please raise issue with kafka-python pro

[jira] [Resolved] (KAFKA-3550) Broker does not honor MetadataRequest api version; always returns v0 MetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-3550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3550. -- Resolution: Fixed Closing as per above comment. > Broker does not honor MetadataRequest api version; al

Build failed in Jenkins: kafka-trunk-jdk7 #3265

See Changes: [github] KAFKA-6672; ConfigCommand should create config change parent path if -- [...truncated 1.53 MB...] org.apache.kafka.streams.integration.KStreamsFineG

[jira] [Resolved] (KAFKA-3238) Deadlock Mirrormaker consumer not fetching any messages

[ https://issues.apache.org/jira/browse/KAFKA-3238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3238. -- Resolution: Auto Closed Closing inactive issue.  old consumer client is no longer supported.  In newer

Jenkins build is back to normal : kafka-1.0-jdk7 #172

See

Build failed in Jenkins: kafka-1.1-jdk7 #87

See Changes: [jason] KAFKA-6672; ConfigCommand should create config change parent path if -- [...truncated 417.05 KB...] kafka.tools.ConsoleConsumerTest > shouldParseValidNew