[jira] [Created] (KAFKA-5859) Avoid retaining AbstractRequest in RequestChannel.Request

Ismael Juma created KAFKA-5859: -- Summary: Avoid retaining AbstractRequest in RequestChannel.Request Key: KAFKA-5859 URL: https://issues.apache.org/jira/browse/KAFKA-5859 Project: Kafka Issue

[jira] [Commented] (KAFKA-5239) Producer buffer pool allocates memory inside a lock.

[ https://issues.apache.org/jira/browse/KAFKA-5239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16158024#comment-16158024 ] Ismael Juma commented on KAFKA-5239: I think it's fine to leave this in 1.0.0. > Producer buffer pool

[jira] [Resolved] (KAFKA-5858) consumer.poll() shouldn't throw exception due to deserialization error

[ https://issues.apache.org/jira/browse/KAFKA-5858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5858. Resolution: Duplicate Duplicate of KAFKA-5470, > consumer.poll() shouldn't throw exception due to

[jira] [Commented] (KAFKA-5857) Excessive heap usage on controller node during reassignment

[ https://issues.apache.org/jira/browse/KAFKA-5857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157992#comment-16157992 ] Ted Yu commented on KAFKA-5857: --- Did you manage to get jmap heap dump before the OOME ? > Excessive heap

[jira] [Commented] (KAFKA-5857) Excessive heap usage on controller node during reassignment

[ https://issues.apache.org/jira/browse/KAFKA-5857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157991#comment-16157991 ] Ted Yu commented on KAFKA-5857: --- bq. After step 5 You listed 4 steps. Did you mean 'after step 4' ? >

[jira] [Commented] (KAFKA-5858) consumer.poll() shouldn't throw exception due to deserialization error

[ https://issues.apache.org/jira/browse/KAFKA-5858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157902#comment-16157902 ] Jun Rao commented on KAFKA-5858: [~hachikuji], any caveats for doing this? > consumer.poll() shouldn't

[jira] [Commented] (KAFKA-5820) Remove unneeded synchronized keyword in StreamThread

[ https://issues.apache.org/jira/browse/KAFKA-5820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157901#comment-16157901 ] ASF GitHub Bot commented on KAFKA-5820: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (KAFKA-5820) Remove unneeded synchronized keyword in StreamThread

[ https://issues.apache.org/jira/browse/KAFKA-5820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5820. -- Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 3777

[jira] [Commented] (KAFKA-2376) Add Kafka Connect metrics

[ https://issues.apache.org/jira/browse/KAFKA-2376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157895#comment-16157895 ] Randall Hauch commented on KAFKA-2376: -- Completed the first draft of

[jira] [Commented] (KAFKA-5657) Connect REST API should include the connector type when describing a connector

[ https://issues.apache.org/jira/browse/KAFKA-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157887#comment-16157887 ] Ted Yu commented on KAFKA-5657: --- [~rhauch]: Can you take a look ? > Connect REST API should include the

[jira] [Updated] (KAFKA-5857) Excessive heap usage on controller node during reassignment

[ https://issues.apache.org/jira/browse/KAFKA-5857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raoufeh Hashemian updated KAFKA-5857: - Description: I was trying to expand our kafka cluster of 6 broker nodes to 12 broker

[jira] [Resolved] (KAFKA-5698) Sort processor node based on name suffix in TopologyDescription.toString()

[ https://issues.apache.org/jira/browse/KAFKA-5698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5698. -- Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 3618

[jira] [Commented] (KAFKA-5839) Upgrade Guide doc changes for KIP-130

[ https://issues.apache.org/jira/browse/KAFKA-5839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157682#comment-16157682 ] Matthias J. Sax commented on KAFKA-5839: No worries. Was just not sure if you want to pick it up

[jira] [Updated] (KAFKA-5657) Connect REST API should include the connector type when describing a connector

[ https://issues.apache.org/jira/browse/KAFKA-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5657: -- Attachment: 5657.v1.txt Is this something close to what you look for ? > Connect REST API should include the

[jira] [Commented] (KAFKA-3033) Reassigning partition stuck in progress

[ https://issues.apache.org/jira/browse/KAFKA-3033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157657#comment-16157657 ] Leo Xuzhang Lin commented on KAFKA-3033: Thanks for the followup! > Reassigning partition stuck

[jira] [Resolved] (KAFKA-3033) Reassigning partition stuck in progress

[ https://issues.apache.org/jira/browse/KAFKA-3033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3033. -- Resolution: Duplicate Resolving this as a duplicate of KAFKA-4914. > Reassigning partition stuck in

[jira] [Resolved] (KAFKA-4190) kafka-reassign-partitions does not report syntax problem in json

[ https://issues.apache.org/jira/browse/KAFKA-4190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4190. -- Resolution: Duplicate Resolving this duplicated KAFKA-4914. KAFKA-4914 PR is being reviewed now. >

[jira] [Resolved] (KAFKA-4119) Get topic offset with Kafka SSL

[ https://issues.apache.org/jira/browse/KAFKA-4119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4119. -- Resolution: Cannot Reproduce Please reopen if the issue still exists. > Get topic offset with Kafka

[jira] [Resolved] (KAFKA-4020) Kafka consumer stop taking messages from kafka server

[ https://issues.apache.org/jira/browse/KAFKA-4020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4020. -- Resolution: Fixed Please reopen if the issue still exists. > Kafka consumer stop taking messages

[jira] [Resolved] (KAFKA-1993) Enable topic deletion as default

[ https://issues.apache.org/jira/browse/KAFKA-1993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1993. -- Resolution: Fixed Resolving this as duplicate of KAFKA-5384 > Enable topic deletion as default >

[jira] [Resolved] (KAFKA-3113) Kafka simple consumer inconsistent result

[ https://issues.apache.org/jira/browse/KAFKA-3113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3113. -- Resolution: Cannot Reproduce may be seed broker is different for different topics. simpleconsumer

[jira] [Updated] (KAFKA-2376) Add Kafka Connect metrics

[ https://issues.apache.org/jira/browse/KAFKA-2376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-2376: - Description: Kafka Connect needs good metrics for monitoring since that will be the primary

[jira] [Resolved] (KAFKA-2022) simpleconsumer.fetch(req) throws a java.nio.channels.ClosedChannelException: null exception when the original leader fails instead of being trapped in the fetchResponse

[ https://issues.apache.org/jira/browse/KAFKA-2022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2022. -- Resolution: Won't Fix I think we need to catch the exception and retry with a new leader. Pl reopen

[jira] [Commented] (KAFKA-5723) Refactor BrokerApiVersionsCommand to use AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157505#comment-16157505 ] Paolo Patierno commented on KAFKA-5723: --- [~adyachkov] I'll do that no worries ! Btw I have commented

[jira] [Resolved] (KAFKA-2623) Kakfa broker not deleting logs after configured retention time properly

[ https://issues.apache.org/jira/browse/KAFKA-2623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2623. -- Resolution: Fixed Time-based log retention is enforced in KIP-33. Pl reopen if you think the issue

[jira] [Commented] (KAFKA-5839) Upgrade Guide doc changes for KIP-130

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

[jira] [Comment Edited] (KAFKA-1455) Expose ConsumerOffsetChecker as an api instead of being command line only

[ https://issues.apache.org/jira/browse/KAFKA-1455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157395#comment-16157395 ] Manikumar edited comment on KAFKA-1455 at 9/7/17 7:22 PM: -- listGroupOffsets

[jira] [Comment Edited] (KAFKA-1455) Expose ConsumerOffsetChecker as an api instead of being command line only

[ https://issues.apache.org/jira/browse/KAFKA-1455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157395#comment-16157395 ] Manikumar edited comment on KAFKA-1455 at 9/7/17 7:01 PM: -- This is has been added

[jira] [Commented] (KAFKA-1455) Expose ConsumerOffsetChecker as an api instead of being command line only

[ https://issues.apache.org/jira/browse/KAFKA-1455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157436#comment-16157436 ] Arup Malakar commented on KAFKA-1455: - Thank you for the update [~omkreddy] > Expose

[jira] [Resolved] (KAFKA-2166) Recreation breaks topic-list

[ https://issues.apache.org/jira/browse/KAFKA-2166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2166. -- Resolution: Fixed Deletion related issues are fixed in newer versions. Pl reopen if you think the

[jira] [Commented] (KAFKA-4585) KIP-163: Offset fetch and commit requests use the same permissions

[ https://issues.apache.org/jira/browse/KAFKA-4585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157419#comment-16157419 ] ASF GitHub Bot commented on KAFKA-4585: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (KAFKA-1563) High packet rate between brokers in kafka cluster.

[ https://issues.apache.org/jira/browse/KAFKA-1563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1563. -- Resolution: Cannot Reproduce Pl reopen if you think the issue still exists > High packet rate

[jira] [Commented] (KAFKA-5781) Frequent long produce latency periods that result in reduced produce rate.

[ https://issues.apache.org/jira/browse/KAFKA-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157398#comment-16157398 ] Raoufeh Hashemian commented on KAFKA-5781: -- HAs anyone got a chance to look into the logs. I keep

[jira] [Comment Edited] (KAFKA-5781) Frequent long produce latency periods that result in reduced produce rate.

[ https://issues.apache.org/jira/browse/KAFKA-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157398#comment-16157398 ] Raoufeh Hashemian edited comment on KAFKA-5781 at 9/7/17 6:29 PM: -- I was

[jira] [Resolved] (KAFKA-47) Create topic support and new ZK data structures for intra-cluster replication

[ https://issues.apache.org/jira/browse/KAFKA-47?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-47. Resolution: Fixed Closing this umbrella JIRA as all tasks are resolved. > Create topic support and new ZK

[jira] [Resolved] (KAFKA-641) ConsumerOffsetChecker breaks when using dns names x.b.com as opposed to raw public IP for broker.

[ https://issues.apache.org/jira/browse/KAFKA-641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-641. - Resolution: Fixed This is not relevant in newer versions. > ConsumerOffsetChecker breaks when using dns

[jira] [Resolved] (KAFKA-252) Generalize getOffsetsBefore API to a new more general API getLeaderMetadata

[ https://issues.apache.org/jira/browse/KAFKA-252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-252. - Resolution: Fixed These API were handled in newer versions. > Generalize getOffsetsBefore API to a new

[jira] [Resolved] (KAFKA-986) Topic Consumption Across multiple instances of consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-986. - Resolution: Cannot Reproduce > Topic Consumption Across multiple instances of consumer groups >

[jira] [Resolved] (KAFKA-1093) Log.getOffsetsBefore(t, …) does not return the last confirmed offset before t

[ https://issues.apache.org/jira/browse/KAFKA-1093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1093. -- Resolution: Invalid relavent part of the code is not available now. So closing this now. >

[jira] [Resolved] (KAFKA-1197) Count of bytes or messages of a topic stored in kafka

[ https://issues.apache.org/jira/browse/KAFKA-1197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1197. -- Resolution: Fixed Size, LogStartOffset, LogEndOffset are exposed as metrics in newer verions. > Count

[jira] [Commented] (KAFKA-5839) Upgrade Guide doc changes for KIP-130

[ https://issues.apache.org/jira/browse/KAFKA-5839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157282#comment-16157282 ] Matthias J. Sax commented on KAFKA-5839: [~fhussonnois] Are you planning to work on this? Just

[jira] [Commented] (KAFKA-5816) Add Produced class and new to and through overloads to KStream

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

[jira] [Created] (KAFKA-5856) AdminClient should be able to increase number of partitions

Tom Bentley created KAFKA-5856: -- Summary: AdminClient should be able to increase number of partitions Key: KAFKA-5856 URL: https://issues.apache.org/jira/browse/KAFKA-5856 Project: Kafka Issue

[jira] [Commented] (KAFKA-5853) Add WindowedKStream interface and implemenation

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

[jira] [Updated] (KAFKA-5855) records-lag is always zero

[ https://issues.apache.org/jira/browse/KAFKA-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mohsen Zainalpour updated KAFKA-5855: - Affects Version/s: 0.11.0.0 > records-lag is always zero > -- > >

[jira] [Commented] (KAFKA-5855) records-lag is always zero

[ https://issues.apache.org/jira/browse/KAFKA-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157169#comment-16157169 ] Mohsen Zainalpour commented on KAFKA-5855: -- Yes, I tested it with 0.10.1.1 and 0.11.0.0 >

[jira] [Comment Edited] (KAFKA-5855) records-lag is always zero

[ https://issues.apache.org/jira/browse/KAFKA-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157152#comment-16157152 ] Mohsen Zainalpour edited comment on KAFKA-5855 at 9/7/17 4:15 PM: -- I've

[jira] [Comment Edited] (KAFKA-5855) records-lag is always zero

[ https://issues.apache.org/jira/browse/KAFKA-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157152#comment-16157152 ] Mohsen Zainalpour edited comment on KAFKA-5855 at 9/7/17 4:14 PM: -- I've

[jira] [Commented] (KAFKA-5855) records-lag is always zero

[ https://issues.apache.org/jira/browse/KAFKA-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157152#comment-16157152 ] Mohsen Zainalpour commented on KAFKA-5855: -- I've tried with jmxterm and the result is the same :

[jira] [Commented] (KAFKA-5855) records-lag is always zero

[ https://issues.apache.org/jira/browse/KAFKA-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157155#comment-16157155 ] Ted Yu commented on KAFKA-5855: --- Is the behavior the same for 0.11.0.0 ? Thanks > records-lag is always

[jira] [Commented] (KAFKA-3039) Temporary loss of leader resulted in log being completely truncated

[ https://issues.apache.org/jira/browse/KAFKA-3039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157087#comment-16157087 ] Jun Rao commented on KAFKA-3039: Hmm, interesting. Not sure why this is happening. Currently, when a

[jira] [Updated] (KAFKA-4764) Improve diagnostics for SASL authentication failures

[ https://issues.apache.org/jira/browse/KAFKA-4764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-4764: -- Description: At the moment, broker closes the client connection if SASL authentication fails.

[jira] [Created] (KAFKA-5854) Handle SASL authentication failures as non-retriable exceptions in clients

Rajini Sivaram created KAFKA-5854: - Summary: Handle SASL authentication failures as non-retriable exceptions in clients Key: KAFKA-5854 URL: https://issues.apache.org/jira/browse/KAFKA-5854 Project:

[jira] [Updated] (KAFKA-4764) Improve diagnostics for SASL authentication failures

[ https://issues.apache.org/jira/browse/KAFKA-4764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-4764: -- Description: At the moment, broker closes the client connection if SASL authentication fails.

[jira] [Comment Edited] (KAFKA-5723) Refactor BrokerApiVersionsCommand to use AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157009#comment-16157009 ] Paolo Patierno edited comment on KAFKA-5723 at 9/7/17 2:34 PM: --- [~adyachkov]

[jira] [Comment Edited] (KAFKA-5723) Refactor BrokerApiVersionsCommand to use AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157009#comment-16157009 ] Paolo Patierno edited comment on KAFKA-5723 at 9/7/17 2:34 PM: --- [~adyachkov]

[jira] [Comment Edited] (KAFKA-5723) Refactor BrokerApiVersionsCommand to use AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157009#comment-16157009 ] Paolo Patierno edited comment on KAFKA-5723 at 9/7/17 2:33 PM: --- [~adyachkov]

[jira] [Commented] (KAFKA-5723) Refactor BrokerApiVersionsCommand to use AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157009#comment-16157009 ] Paolo Patierno commented on KAFKA-5723: --- [~adyachkov] [~viktorsomogyi] the discussion on how to

[jira] [Updated] (KAFKA-5853) Add WindowedKStream interface and implemenation

[ https://issues.apache.org/jira/browse/KAFKA-5853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5853: -- Description: Add the {{WindowedKStream}} interface and implementation of methods that don't require

[jira] [Assigned] (KAFKA-5853) Add WindowedKStream interface and implemenation

[ https://issues.apache.org/jira/browse/KAFKA-5853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-5853: - Assignee: Damian Guy > Add WindowedKStream interface and implemenation >

[jira] [Created] (KAFKA-5853) Add WindowedKStream interface and implemenation

Damian Guy created KAFKA-5853: - Summary: Add WindowedKStream interface and implemenation Key: KAFKA-5853 URL: https://issues.apache.org/jira/browse/KAFKA-5853 Project: Kafka Issue Type: Sub-task

[jira] [Comment Edited] (KAFKA-5723) Refactor BrokerApiVersionsCommand to use AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156921#comment-16156921 ] Andrey Dyachkov edited comment on KAFKA-5723 at 9/7/17 12:56 PM: -

[jira] [Commented] (KAFKA-5723) Refactor BrokerApiVersionsCommand to use AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156921#comment-16156921 ] Andrey Dyachkov commented on KAFKA-5723: [~viktorsomogyi] [~ppatierno] could we try to merge this

[jira] [Commented] (KAFKA-5830) kafka-configs.sh should allow deletion of all configs for an entity

[ https://issues.apache.org/jira/browse/KAFKA-5830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156896#comment-16156896 ] Rajini Sivaram commented on KAFKA-5830: --- [~mimaison] Since this is a change to the tool, a KIP is

[jira] [Updated] (KAFKA-5561) Refactor TopicCommand to use the Admin client

[ https://issues.apache.org/jira/browse/KAFKA-5561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno updated KAFKA-5561: -- Summary: Refactor TopicCommand to use the Admin client (was: Refactor TopicCommand using the

[jira] [Updated] (KAFKA-5722) Refactor ConfigCommand to use the AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno updated KAFKA-5722: -- Summary: Refactor ConfigCommand to use the AdminClient (was: Refactor ConfigCommand to use the

[jira] [Updated] (KAFKA-5723) Refactor BrokerApiVersionsCommand to use AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno updated KAFKA-5723: -- Summary: Refactor BrokerApiVersionsCommand to use AdminClient (was: Refactor

[jira] [Commented] (KAFKA-5852) Add filter, filterNot, mapValues and Materialized to KTable

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

[jira] [Commented] (KAFKA-5651) KIP-182: Reduce Streams DSL overloads and allow easier use of custom storage engines

[ https://issues.apache.org/jira/browse/KAFKA-5651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156881#comment-16156881 ] Damian Guy commented on KAFKA-5651: --- Sorry [~adyachkov] and [~ckamal] - i didn't see these comments

[jira] [Created] (KAFKA-5852) Add filter, filterNot, mapValues and Materialized to KTable

Damian Guy created KAFKA-5852: - Summary: Add filter, filterNot, mapValues and Materialized to KTable Key: KAFKA-5852 URL: https://issues.apache.org/jira/browse/KAFKA-5852 Project: Kafka Issue

[jira] [Assigned] (KAFKA-5777) Add ducktape integration for the Trogdor Fault injection daemon

[ https://issues.apache.org/jira/browse/KAFKA-5777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram reassigned KAFKA-5777: - Assignee: Colin P. McCabe > Add ducktape integration for the Trogdor Fault injection

[jira] [Commented] (KAFKA-5777) Add ducktape integration for the Trogdor Fault injection daemon

[ https://issues.apache.org/jira/browse/KAFKA-5777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156874#comment-16156874 ] ASF GitHub Bot commented on KAFKA-5777: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (KAFKA-5777) Add ducktape integration for the Trogdor Fault injection daemon

[ https://issues.apache.org/jira/browse/KAFKA-5777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-5777. --- Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 3726

[jira] [Commented] (KAFKA-5844) Add groupBy(KeyValueMapper, Serialized) to KTable

[ https://issues.apache.org/jira/browse/KAFKA-5844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156834#comment-16156834 ] ASF GitHub Bot commented on KAFKA-5844: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (KAFKA-5844) Add groupBy(KeyValueMapper, Serialized) to KTable

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

[jira] [Updated] (KAFKA-5561) Refactor TopicCommand using the new Admin client

[ https://issues.apache.org/jira/browse/KAFKA-5561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno updated KAFKA-5561: -- Summary: Refactor TopicCommand using the new Admin client (was: Rewrite TopicCommand using the

[jira] [Commented] (KAFKA-5650) Provide a simple way for custom storage engines to use streams wrapped stores (KIP-182)

[ https://issues.apache.org/jira/browse/KAFKA-5650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156694#comment-16156694 ] ASF GitHub Bot commented on KAFKA-5650: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-5845) KafkaController should send LeaderAndIsrRequest to broker which starts very soon after shutdown

[ https://issues.apache.org/jira/browse/KAFKA-5845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156658#comment-16156658 ] James Cheng commented on KAFKA-5845: Is this related to KAFKA-1120? /cc [~onurkaraman] >

[jira] [Commented] (KAFKA-5816) Add Produced class and new to and through overloads to KStream

[ https://issues.apache.org/jira/browse/KAFKA-5816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156640#comment-16156640 ] ASF GitHub Bot commented on KAFKA-5816: --- Github user asfgit closed the pull request at:

[jira] [Created] (KAFKA-5851) CPU overhead to having partitions (even inactive)

Stephane Maarek created KAFKA-5851: -- Summary: CPU overhead to having partitions (even inactive) Key: KAFKA-5851 URL: https://issues.apache.org/jira/browse/KAFKA-5851 Project: Kafka Issue

[jira] [Created] (KAFKA-5850) Py4JJavaError: An error occurred while calling o40.loadClass. : java.lang.ClassNotFoundException: org.apache.spark.streaming.kafka.KafkaUtilsPythonHelper

Saurabh Bidwai created KAFKA-5850: - Summary: Py4JJavaError: An error occurred while calling o40.loadClass. : java.lang.ClassNotFoundException: org.apache.spark.streaming.kafka.KafkaUtilsPythonHelper Key: KAFKA-5850

[jira] [Commented] (KAFKA-5797) StoreChangelogReader should be resilient to broker-side metadata not available

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