Comparing Pulsar and Kafka: unified queuing and streaming

Dear Kafka Community, I happened to read this blog post comparing the messaging model between Apache Pulsar and Apache Kafka. It sounds interesting. Apache Pulsar claims to unify streaming (kafka) and queuing (rabbitmq) in one unified API. Pulsar also seems to support Kafka API. Have anyone taken

[jira] [Created] (KAFKA-6305) log.retention.hours, retention.ms not working in segments deletion for kafka topic

VinayKumar created KAFKA-6305: - Summary: log.retention.hours, retention.ms not working in segments deletion for kafka topic Key: KAFKA-6305 URL: https://issues.apache.org/jira/browse/KAFKA-6305 Project:

[jira] [Created] (KAFKA-6304) The controller should allow update the partition reassignment for the partitions being reassigned

Jiangjie Qin created KAFKA-6304: --- Summary: The controller should allow update the partition reassignment for the partitions being reassigned Key: KAFKA-6304 URL: https://issues.apache.org/jira/browse/KAFKA-6304

[jira] [Created] (KAFKA-6303) Potential lack of synchronization in NioEchoServer#AcceptorThread

Ted Yu created KAFKA-6303: - Summary: Potential lack of synchronization in NioEchoServer#AcceptorThread Key: KAFKA-6303 URL: https://issues.apache.org/jira/browse/KAFKA-6303 Project: Kafka Issue

Re: [DISCUSS] KIP-227: Introduce Incremental FetchRequests to Increase Partition Scalability

>The correlation ID is used within a single TCP session, to uniquely >associate a request with a response. The correlation ID is not unique >(and has no meaning) outside the context of that single TCP session. > >Keep in mind, NetworkClient is in charge of TCP sessions, and generally >tries to

Re: [DISCUSS] KIP-227: Introduce Incremental FetchRequests to Increase Partition Scalability

On Sat, Dec 2, 2017, at 23:21, Becket Qin wrote: > Thanks for the explanation, Colin. A few more questions. > > >The session epoch is not complex. It's just a number which increments > >on each incremental fetch. The session epoch is also useful for > >debugging-- it allows you to match up

[GitHub] kafka pull request #4289: KAFKA-6301 changing regular expression in ops.html...

GitHub user waleedfateem opened a pull request: https://github.com/apache/kafka/pull/4289 KAFKA-6301 changing regular expression in ops.html from '*' to '.*' The documentation for section "Mirroring data between clusters" states the following: Or you could mirror all topics

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

See

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

See

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

See Changes: [wangguoz] MINOR: Fix broker compatibility tests -- [...truncated 1.42 MB...] org.apache.kafka.common.config.ConfigDefTest > testValidateCannotParse STARTED

[GitHub] kafka pull request #4286: MINOR: fix broker compatibility tests

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/4286 ---

[jira] [Created] (KAFKA-6302) Topic can not be recreated after it is deleted

kic created KAFKA-6302: -- Summary: Topic can not be recreated after it is deleted Key: KAFKA-6302 URL: https://issues.apache.org/jira/browse/KAFKA-6302 Project: Kafka Issue Type: Bug

Documentation JIRA KAFKA-6301 and access to repo

Hello, I created a JIRA (KAFKA-6301) for a minor change to the documentation but it doesn't seem like I can assign the ticket to myself. Can someone help me out? I'm also trying to commit and push the change to the Kafka repository but I'm getting the following error: remote: Permission to

[jira] [Created] (KAFKA-6301) Incorrect Java Regex example '*' for mirroring all topics

Waleed Fateem created KAFKA-6301: Summary: Incorrect Java Regex example '*' for mirroring all topics Key: KAFKA-6301 URL: https://issues.apache.org/jira/browse/KAFKA-6301 Project: Kafka

Re: [DISCUSS] KIP-227: Introduce Incremental FetchRequests to Increase Partition Scalability

On 02.12.2017 23:34, Colin McCabe wrote: On Thu, Nov 30, 2017, at 23:29, Jan Filipiak wrote: Hi, this discussion is going a little bit far from what I intended this thread for. I can see all of this beeing related. To let you guys know what I am currently thinking is the following: I do