[jira] [Created] (KAFKA-6987) Reimplement KafkaFuture with CopletableFuture

Andras Beni created KAFKA-6987: -- Summary: Reimplement KafkaFuture with CopletableFuture Key: KAFKA-6987 URL: https://issues.apache.org/jira/browse/KAFKA-6987 Project: Kafka Issue Type: Improveme

[VOTE] KIP-280: Enhanced log compaction

Hi all, After a thorough discussion, this KIP is now ready to go into a vote:  KIP-280: Enhanced log compaction - Apache Kafka - Apache Software Foundation | | | | KIP-280: Enhanced log compaction - Apache Kafka - Apache Software Founda... | | | Kind Regards, Luís CabralOn

Re: [DISCUSS] KIP-308: GetOffsetShell: new KafkaConsumer API, support for multiple topics, minimize the number of requests to server

Hi Arseniy, A few comments from me collected in points: 1. Usually the commands use "bootstrap-server" as in singular and not the plural "bootstrap-servers", so I suggest to keep this functionality. Otherwise their behavior is still the same. 2. kafka-get-offsets.sh --bootstrap-servers vm:9092 -

[jira] [Created] (KAFKA-6988) Kafka windows classpath too long

lkgen created KAFKA-6988: Summary: Kafka windows classpath too long Key: KAFKA-6988 URL: https://issues.apache.org/jira/browse/KAFKA-6988 Project: Kafka Issue Type: Bug Components: core

Re: [VOTE] KIP-280: Enhanced log compaction

Thanks Luís for working on this KIP. I'm +1. One note is that there is another KIP, KIP-228 going on for allowing negative timestamp (I'm cc'ing the contributor of that KIP as well). One related issue from KIP-228 is the handling of "-1": we will treat all other negative values normally as some ti

[jira] [Reopened] (KAFKA-6281) Kafka JavaAPI Producer failed with NotLeaderForPartitionException

[ https://issues.apache.org/jira/browse/KAFKA-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anil reopened KAFKA-6281: - Thanks [~omkreddy],  We've got this issue again today, twice.  I see that both the times, there is GC running in my

[jira] [Created] (KAFKA-6989) Support Async Processing in Streams

Guozhang Wang created KAFKA-6989: Summary: Support Async Processing in Streams Key: KAFKA-6989 URL: https://issues.apache.org/jira/browse/KAFKA-6989 Project: Kafka Issue Type: Improvement

Re: [jira] [Created] (KAFKA-6989) Support Async Processing in Streams

Hi All, I am a Java Enginner, new to Kafka and would like to contribute as a *committer*. Could anyone please help me on this? Where to start how to start? Thanks Soumya

[jira] [Created] (KAFKA-6990) CommitFailedException; this task may be no longer owned by the thread

Eugen Feller created KAFKA-6990: --- Summary: CommitFailedException; this task may be no longer owned by the thread Key: KAFKA-6990 URL: https://issues.apache.org/jira/browse/KAFKA-6990 Project: Kafka

[jira] [Resolved] (KAFKA-6938) Add documentation for accessing Headers on Kafka Streams Processor API

[ https://issues.apache.org/jira/browse/KAFKA-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6938. -- Resolution: Fixed > Add documentation for accessing Headers on Kafka Streams Processor API > --

[jira] [Resolved] (KAFKA-5632) Message headers not supported by Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-5632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5632. -- Resolution: Duplicate > Message headers not supported by Kafka Streams > --

[DISCUSS] KIP-310: Add a Kafka Source Connector to Kafka Connect

Hi All, As I didn’t get any comment on this KIP and there has since been an additional 2 KIP’s created numbered 308 since, I'm bumping this and renaming the KIP to 310 to remove the duplication: https://cwiki.apache.org/confluence/display/KAFKA/KIP-310%3A+Add+a+Kafka+Source+Connector+to+Kafka+C

Re: [DISCUSS] KIP-253: Support in-order message delivery with partition expansion

Hi all, Not sure if there is further concern with this KIP. And the vote for KIP-232 is also blocked on the discussion of this KIP. I am happy to continue the discussion and move forward the progress of this KIP. Thanks, Dong On Tue, Apr 17, 2018 at 8:58 PM, Jeff Chao wrote: > Hi Dong, I took

Re: [jira] [Created] (KAFKA-6989) Support Async Processing in Streams

Soumya, thanks a lot for your interest in contributing to Kafka! If you are new to the project, I would recommend to pick a JIRA that is labeled as "newbie" or "beginner". Adding a complex feature like KAFKA-6989 might be a second step. Of course, if you feel confident enough to tackle this from

Re: [VOTE] KIP-232: Detect outdated metadata using leaderEpoch and partitionEpoch

Hey Jun, It seems that we have made considerable progress on the discussion of KIP-253 since February. Do you think we should continue the discussion there, or can we continue the voting for this KIP? I am happy to submit the PR and move forward the progress for this KIP. Thanks! Dong On Wed, F

[jira] [Created] (KAFKA-6991) Connect Rest Extension Plugin issue with Class Loader

Magesh kumar Nandakumar created KAFKA-6991: -- Summary: Connect Rest Extension Plugin issue with Class Loader Key: KAFKA-6991 URL: https://issues.apache.org/jira/browse/KAFKA-6991 Project: Kafka

[jira] [Created] (KAFKA-6992) Configuring the batch.size to zero won't disable the batching entirely

Chia-Ping Tsai created KAFKA-6992: - Summary: Configuring the batch.size to zero won't disable the batching entirely Key: KAFKA-6992 URL: https://issues.apache.org/jira/browse/KAFKA-6992 Project: Kafka