[GitHub] kafka pull request #3999: MINOR: Add attributes `processedKeys` and `process...

GitHub user mewwts opened a pull request: https://github.com/apache/kafka/pull/3999 MINOR: Add attributes `processedKeys` and `processedValues` to MockProcessorSupplier This would allow for easier testing of topologies using the following pattern: ```Scala // in Scala v

[jira] [Created] (KAFKA-6000) streams 0.10.2.1 - kafka 0.11.0.1 state restore not working

Bart Vercammen created KAFKA-6000: - Summary: streams 0.10.2.1 - kafka 0.11.0.1 state restore not working Key: KAFKA-6000 URL: https://issues.apache.org/jira/browse/KAFKA-6000 Project: Kafka

Re: [DISCUSS] KIP-179: Change ReassignPartitionsCommand to use AdminClient

One question I have is about whether/how to scope throttling to a reassignment. Currently throttles are only loosely associated with reassignment: You can start a reassignment without any throttling, add throttling to an in-flight reassignment, and remember/forget to remove throttling after the rea

[GitHub] kafka pull request #4000: KAFKA-5445: Document exceptions thrown by AdminCli...

GitHub user adyach opened a pull request: https://github.com/apache/kafka/pull/4000 KAFKA-5445: Document exceptions thrown by AdminClient methods Exceptions are processed internally in KafkaAdminClient without throwing them to the client code, hence the documentation of the exceptio

[DISCUSS] URIs on Producer and Consumer

At ActiveMQ and ActiveMQ Artemis, ConnectionFactories have an interesting feature where you can pass parameters through an URI. I was looking at Producer and Consumer APIs, and these two classes are using a method that I considered old for Artemis resembling HornetQ: Instead of passing a Properti

Re: [DISCUSS] KIP-201: Rationalising Policy interfaces

Hi All, I've updated KIP-201 again so there is now a single policy interface (and thus a single key by which to configure it) for topic creation, modification, deletion and record deletion, which each have their own validation method. There are still a few loose ends: 1. I currently propose vali

[GitHub] kafka-site pull request #77: MINOR: Add streams child topics to left-hand na...

Github user joel-hamill commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/77#discussion_r142175889 --- Diff: includes/_nav.htm --- @@ -11,6 +11,12 @@ getting started APIs kafka streams + --- End

[jira] [Created] (KAFKA-6001) Remove from usages of Materialized in Streams

Damian Guy created KAFKA-6001: - Summary: Remove from usages of Materialized in Streams Key: KAFKA-6001 URL: https://issues.apache.org/jira/browse/KAFKA-6001 Project: Kafka Issue Type: Bug

[GitHub] kafka pull request #4001: KAFKA-6001: remove from Materializ...

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/4001 KAFKA-6001: remove from Materialized usages Make the API simpler by removing `` from usages of `Materialized`. This is already enforced when by `Materialized.as(KeyValueBytesStore)` etc. You can mer

[GitHub] kafka pull request #4002: KAFKA-5989: resume consumption of tasks that have ...

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/4002 KAFKA-5989: resume consumption of tasks that have state stores but no changelogging Stores where logging is disabled where never consumed as the partitions were paused, but never resumed. You can mer

[jira] [Created] (KAFKA-6002) Kafka Connect Transform transforming JSON string into actual object

Edvard Poliakov created KAFKA-6002: -- Summary: Kafka Connect Transform transforming JSON string into actual object Key: KAFKA-6002 URL: https://issues.apache.org/jira/browse/KAFKA-6002 Project: Kafka

[jira] [Resolved] (KAFKA-5985) Mention the need to close store iterators

[ https://issues.apache.org/jira/browse/KAFKA-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5985. --- Resolution: Fixed Issue resolved by pull request 3994 [https://github.com/apache/kafka/pull/3994] > M

[GitHub] kafka pull request #3994: KAFKA-5985: update javadoc regarding closing itera...

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

[GitHub] kafka pull request #4003: MINOR: add suppress warnings annotations

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/4003 MINOR: add suppress warnings annotations You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka minor-deprecated Alternatively you can revie

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

See Changes: [damian.guy] KAFKA-5985; update javadoc regarding closing iterators -- [...truncated 370.10 KB...] kafka.server.epoch.LeaderEpochFileCacheTest > shouldNotCle

[GitHub] kafka pull request #3405: KAFKA-5495: Update docs to use `kafka-consumer-gro...

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

[jira] [Created] (KAFKA-6003) Replication Fetcher thread for a partition with no data fails to start

Stanislav Chizhov created KAFKA-6003: Summary: Replication Fetcher thread for a partition with no data fails to start Key: KAFKA-6003 URL: https://issues.apache.org/jira/browse/KAFKA-6003 Project:

[GitHub] kafka-site issue #77: MINOR: Add streams child topics to left-hand nav

Github user dguy commented on the issue: https://github.com/apache/kafka-site/pull/77 @miguno ---

[GitHub] kafka pull request #3971: MINOR: additional kip-182 doc updates

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

[GitHub] kafka-site issue #77: MINOR: Add streams child topics to left-hand nav

Github user joel-hamill commented on the issue: https://github.com/apache/kafka-site/pull/77 @derrickdoo ping ^ ---

[GitHub] kafka-site pull request #78: MINOR: Add header items

Github user joel-hamill closed the pull request at: https://github.com/apache/kafka-site/pull/78 ---

[GitHub] kafka pull request #3970: KAFKA-5225: StreamsResetter doesn't allow custom C...

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

[jira] [Created] (KAFKA-6004) Enable custom authentication plugins to return error messages to clients

Rajini Sivaram created KAFKA-6004: - Summary: Enable custom authentication plugins to return error messages to clients Key: KAFKA-6004 URL: https://issues.apache.org/jira/browse/KAFKA-6004 Project: Kaf

Re: [DISCUSS] KIP-206: Add support for UUID serialization and deserialization

Hi, Unless there are some further discussion points, I will put this KIP for vote tomorrow around this time. Thanks & Regards Jakub On Tue, Sep 26, 2017 at 7:27 PM, Jakub Scholz wrote: > Hi Ted, > > Thanks. The link to this thread is there now. > > Regards > Jakub > > On Tue, Sep 26, 2017 at 7

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

See

[GitHub] kafka pull request #3954: KAFKA-5758: Don't fail fetch request if replica is...

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

[GitHub] kafka-site issue #77: MINOR: Add streams child topics to left-hand nav

Github user joel-hamill commented on the issue: https://github.com/apache/kafka-site/pull/77 after talking with @derrickdoo, I have removed the changes to the left-hand nav. ---

[GitHub] kafka pull request #4004: KAFKA-6003: Accept appends on replicas uncondition...

GitHub user apurvam opened a pull request: https://github.com/apache/kafka/pull/4004 KAFKA-6003: Accept appends on replicas unconditionally when local producer state doesn't exist Without this patch, if the replica's log was somehow truncated before the leader's it is possible f

Consumer Offsets partition skew on Kafka 0.10.1.1

I was investigating some performance issues we're issues in one of our production clusters, and I ran into extremely unbalanced offset partitions for the __consumer_offsets topic. I only pasted the top 8 below, out of 50 total. As you can see, between the top 5 partitions, those servers have to h

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

See Changes: [ismael] KAFKA-5758; Don't fail fetch request if replica is no longer a follower -- [...truncated 3.86 MB...] org.apache.kafka.connect.runtime.distributed.Dis

[GitHub] kafka pull request #4005: MINOR: fix JavaDocs warnings

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/4005 MINOR: fix JavaDocs warnings - add some missing annotations for deprecated methods You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka min

[jira] [Resolved] (KAFKA-5995) Rename AlterReplicaDir to AlterReplicaDirs

[ https://issues.apache.org/jira/browse/KAFKA-5995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-5995. Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 3993 [https://github.com/apache

[GitHub] kafka pull request #3993: KAFKA-5995; Rename AlterReplicaDir to AlterReplica...

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

[VOTE] KIP-204 : adding records deletion operation to the new Admin Client API

Hi all, I didn't see any further discussion around this KIP, so I'd like to start the vote for it. Just for reference : https://cwiki.apache.org/confluence/display/KAFKA/KIP-204+%3A+adding+records+deletion+operation+to+the+new+Admin+Client+API Thanks, Paolo Patierno Senior Software Engineer

Re: [VOTE] KIP-176 : Remove deprecated new-consumer option for tools

Just as reminder for other committers in order to have other binding votes, for now we have ... binding +1 Ismael Juma +1 Guozhang Wang non binding +1 Mickael Maison +1 Vahid Hashemian Paolo Patierno Senior Software Engineer (IoT) @ Red Hat Microsoft MVP on Azure & IoT Microsoft Azure Ad

[GitHub] kafka-site issue #77: MINOR: Add streams child topics to left-hand nav

Github user miguno commented on the issue: https://github.com/apache/kafka-site/pull/77 Could you please edit/update the PR title then? I understand that this PR is now a change to the content pane of the main page (kafka.apache.org) only? ---