[GitHub] kafka pull request #2152: MINOR: make serializer classes final

GitHub user MatthiasBechtold opened a pull request: https://github.com/apache/kafka/pull/2152 MINOR: make serializer classes final implementations of simple serializers / deserializers should be final to prevent JVM method call overhead. See also: https://wiki.openjdk.java.n

Re?? [DISCUSS] KIP-68 Add a consumed log retention before log retention

Hi Guozhang, I do agree to make the broker simple, but the consumer retention process is not so complex though(working on the same thread of log retention thread, just add some querying offset procedure), and is disabled by default, I will update the patch as soon as possible you can see it

[jira] [Created] (KAFKA-4424) Make serializer classes final

Matthias Bechtold created KAFKA-4424: Summary: Make serializer classes final Key: KAFKA-4424 URL: https://issues.apache.org/jira/browse/KAFKA-4424 Project: Kafka Issue Type: Improvement

Resources about Apache Kafka

Hi, I am looking for Apache Kafka documentations and related sources that describe about Apache Kafka core module and it's implementation. Specially interested in how kafkaConsumer fetch requests are handled in broker side and brokers, end points and partition behaviors. I am so grateful if someo

Re: [jira] [Created] (KAFKA-4424) Make serializer classes final

This is a change to api level / client code making it more restrictive as such would break code that has extended these classes. we should therefor have a KIP for this. At this time I would vote: -1 this will break any existing code by organisations for imo unproven performance improvement. I

[jira] [Commented] (KAFKA-4424) Make serializer classes final

[ https://issues.apache.org/jira/browse/KAFKA-4424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15681447#comment-15681447 ] Michael Andre Pearce (IG) commented on KAFKA-4424: -- Is there a supporting

[jira] [Created] (KAFKA-4425) Topic created with CreateTopic command not listed in Metadata

Mark de Jong created KAFKA-4425: --- Summary: Topic created with CreateTopic command not listed in Metadata Key: KAFKA-4425 URL: https://issues.apache.org/jira/browse/KAFKA-4425 Project: Kafka Is

[jira] [Updated] (KAFKA-4425) Topic created with CreateTopic command not listed in Metadata

[ https://issues.apache.org/jira/browse/KAFKA-4425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark de Jong updated KAFKA-4425: Description: With the release of Kafka 0.10.10 there are now commands to delete and create topics v

[jira] [Updated] (KAFKA-4425) Topic created with CreateTopic command, does not list partitions in metadata

[ https://issues.apache.org/jira/browse/KAFKA-4425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark de Jong updated KAFKA-4425: Summary: Topic created with CreateTopic command, does not list partitions in metadata (was: Topic c

Re: Resources about Apache Kafka

Not sure if this answers your question, but the entry point for handling the FetchRequest is here: https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/server/KafkaApis.scala#L436 That file has the entry points for the handlers of other requests as well. Thanks, Apurva On Sun, No

[GitHub] kafka pull request #2102: KAFKA-2284: corrects value type in beforeReleasing...

Github user leachbj closed the pull request at: https://github.com/apache/kafka/pull/2102 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is ena

[jira] [Commented] (KAFKA-2284) ConsumerRebalanceListener receives wrong type in partitionOwnership values

[ https://issues.apache.org/jira/browse/KAFKA-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15681902#comment-15681902 ] ASF GitHub Bot commented on KAFKA-2284: --- Github user leachbj closed the pull request

[jira] [Assigned] (KAFKA-4378) Address 2.12 eta-expansion warnings

[ https://issues.apache.org/jira/browse/KAFKA-4378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bernard Leach reassigned KAFKA-4378: Assignee: Bernard Leach > Address 2.12 eta-expansion warnings > ---

scala 2.12 artifacts

Hi all, With the recent release of scala 2.12 the community has been working toward getting libraries released as 2.12 compiled binaries. Although Kafka isn’t a typical development library the scalatest-embedded-kafka project (https://github.com/manub/scalatest-embedded-kafka

[jira] [Commented] (KAFKA-4425) Topic created with CreateTopic command, does not list partitions in metadata

[ https://issues.apache.org/jira/browse/KAFKA-4425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15682220#comment-15682220 ] huxi commented on KAFKA-4425: - What timeout value do you specify in the TopicDetails? > Topic

[GitHub] kafka pull request #2128: KAFKA-4402: make the KafkaProducer true round robi...

GitHub user yaojuncn reopened a pull request: https://github.com/apache/kafka/pull/2128 KAFKA-4402: make the KafkaProducer true round robin per topic You can merge this pull request into a Git repository by running: $ git pull https://github.com/yaojuncn/kafka KAFKA-4402-clie

[jira] [Commented] (KAFKA-4402) Kafka Producer's DefaultPartitioner is actually not round robin as said in the code comments "If no partition or key is present choose a partition in a round-robin fash

[ https://issues.apache.org/jira/browse/KAFKA-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15682502#comment-15682502 ] ASF GitHub Bot commented on KAFKA-4402: --- GitHub user yaojuncn reopened a pull reques

[GitHub] kafka pull request #2128: KAFKA-4402: make the KafkaProducer true round robi...

Github user yaojuncn closed the pull request at: https://github.com/apache/kafka/pull/2128 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is en

[jira] [Commented] (KAFKA-4402) Kafka Producer's DefaultPartitioner is actually not round robin as said in the code comments "If no partition or key is present choose a partition in a round-robin fash

[ https://issues.apache.org/jira/browse/KAFKA-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15682501#comment-15682501 ] ASF GitHub Bot commented on KAFKA-4402: --- Github user yaojuncn closed the pull reques

[GitHub] kafka pull request #2153: MINOR: Update JavaDoc of KStream interface

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/2153 MINOR: Update JavaDoc of KStream interface You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka javaDocKStreams Alternatively you can revi

[jira] [Commented] (KAFKA-4425) Topic created with CreateTopic command, does not list partitions in metadata

[ https://issues.apache.org/jira/browse/KAFKA-4425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15682786#comment-15682786 ] Mark de Jong commented on KAFKA-4425: - 5000 > Topic created with CreateTopic command,