[GitHub] kafka pull request #2740: MINOR: Use method handles instead of reflection fo...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/2740 MINOR: Use method handles instead of reflection for creating Snappy and LZ4 streams Also remove unused `ByteBufferReceive`. You can merge this pull request into a Git repository by running: $ gi

[jira] [Commented] (KAFKA-1449) Extend wire protocol to allow CRC32C

[ https://issues.apache.org/jira/browse/KAFKA-1449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942069#comment-15942069 ] ASF GitHub Bot commented on KAFKA-1449: --- GitHub user ijuma opened a pull request:

[GitHub] kafka pull request #2739: KAFKA-1449: Use CRC32C for checksum of V2 message ...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/2739 KAFKA-1449: Use CRC32C for checksum of V2 message format You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka kafka-1449-crc32c Alternativ

Re: [DISCUSS] KIP 130: Expose states of active tasks to KafkaStreams public API

Re 1): this is a good point. May be we can move `StreamsMetadata#streamThreads` as `KafkaStreams#localThreadsMetadata`? 3): this is a minor suggestion about function name of `assignedPartitions`, to `topicPartitions` to be consistent with `StreamsMetadata`? Guozhang On Thu, Mar 23, 2017 at 4:30

Fwd: [DISCUSS] KIP 130: Expose states of active tasks to KafkaStreams public API

Forwarding Matthias's reply to the channel (I think he meant to do that but reply only to me). -- Forwarded message -- From: Matthias J. Sax Date: Thu, Mar 23, 2017 at 4:30 PM Subject: Re: [DISCUSS] KIP 130: Expose states of active tasks to KafkaStreams public API To: Guozhang Wan

[GitHub] kafka pull request #2738: MINOR: Support streaming decompression of fetched ...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2738 MINOR: Support streaming decompression of fetched records for new format You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka strea

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

See

[GitHub] kafka pull request #2737: MINOR: Fix deserialization of abortedTransactions ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2737 --- 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 enab

[GitHub] kafka pull request #2737: MINOR: Fix deserialization of abortedTransactions ...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/2737 MINOR: Fix deserialization of abortedTransactions and lastStableOffset in FetchResponse Thanks to Dong Lin for catching the issue. You can merge this pull request into a Git repository by running:

[jira] [Created] (KAFKA-4950) ConcurrentModificationException when iterating over Kafka Metrics

Dumitru Postoronca created KAFKA-4950: - Summary: ConcurrentModificationException when iterating over Kafka Metrics Key: KAFKA-4950 URL: https://issues.apache.org/jira/browse/KAFKA-4950 Project: Ka

[jira] [Commented] (KAFKA-4938) Creating a connector with missing name parameter throws a NullPointerException

[ https://issues.apache.org/jira/browse/KAFKA-4938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941667#comment-15941667 ] Sönke Liebau commented on KAFKA-4938: - [~baluchicken]: I am working on a pull request