[jira] [Commented] (KAFKA-3478) Finer Stream Flow Control

[ https://issues.apache.org/jira/browse/KAFKA-3478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15458985#comment-15458985 ] Bill Bejeck commented on KAFKA-3478: Makes sense, but I didn't realize that was the case, thanks. >

[jira] [Assigned] (KAFKA-4131) Multiple Regex KStream-Consumers cause Null pointer exception in addRawRecords in RecordQueue class

[ https://issues.apache.org/jira/browse/KAFKA-4131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-4131: -- Assignee: Bill Bejeck (was: Guozhang Wang) > Multiple Regex KStream-Consumers cause Null

[jira] [Commented] (KAFKA-4131) Multiple Regex KStream-Consumers cause Null pointer exception in addRawRecords in RecordQueue class

[ https://issues.apache.org/jira/browse/KAFKA-4131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15467695#comment-15467695 ] Bill Bejeck commented on KAFKA-4131: If it's ok, I'll pick this one up > Multiple Regex

[jira] [Commented] (KAFKA-3478) Finer Stream Flow Control

[ https://issues.apache.org/jira/browse/KAFKA-3478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15458306#comment-15458306 ] Bill Bejeck commented on KAFKA-3478: [~mjsax] thanks for the heads up, but it looks like they are

[jira] [Work started] (KAFKA-4131) Multiple Regex KStream-Consumers cause Null pointer exception in addRawRecords in RecordQueue class

[ https://issues.apache.org/jira/browse/KAFKA-4131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4131 started by Bill Bejeck. -- > Multiple Regex KStream-Consumers cause Null pointer exception in > addRawRecords

[jira] [Updated] (KAFKA-4023) Add thread id as prefix in Kafka Streams thread logging

[ https://issues.apache.org/jira/browse/KAFKA-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-4023: --- Status: Patch Available (was: In Progress) > Add thread id as prefix in Kafka Streams thread logging

[jira] [Work started] (KAFKA-4114) Allow for different "auto.offset.reset" strategies for different input streams

[ https://issues.apache.org/jira/browse/KAFKA-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4114 started by Bill Bejeck. -- > Allow for different "auto.offset.reset" strategies for different input streams >

[jira] [Updated] (KAFKA-4131) Multiple Regex KStream-Consumers cause Null pointer exception in addRawRecords in RecordQueue class

[ https://issues.apache.org/jira/browse/KAFKA-4131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-4131: --- Status: Patch Available (was: In Progress) Working on getting an integration test for this bug fix.

[jira] [Work started] (KAFKA-4269) Multiple KStream instances with at least one Regex source causes NPE when using multiple consumers

[ https://issues.apache.org/jira/browse/KAFKA-4269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4269 started by Bill Bejeck. -- > Multiple KStream instances with at least one Regex source causes NPE when > using

[jira] [Assigned] (KAFKA-4269) Multiple KStream instances with at least one Regex source causes NPE when using multiple consumers

[ https://issues.apache.org/jira/browse/KAFKA-4269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-4269: -- Assignee: Bill Bejeck (was: Guozhang Wang) > Multiple KStream instances with at least one

[jira] [Created] (KAFKA-4269) Multiple KStream instances with at least one Regex source causes NPE when using multiple consumers

Bill Bejeck created KAFKA-4269: -- Summary: Multiple KStream instances with at least one Regex source causes NPE when using multiple consumers Key: KAFKA-4269 URL: https://issues.apache.org/jira/browse/KAFKA-4269

[jira] [Updated] (KAFKA-4269) Multiple KStream instances with at least one Regex source causes NPE when using multiple consumers

[ https://issues.apache.org/jira/browse/KAFKA-4269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-4269: --- Description: I discovered this issue while doing testing for for KAFKA-4114. KAFKA-4131 fixed the

[jira] [Commented] (KAFKA-4114) Allow for different "auto.offset.reset" strategies for different input streams

[ https://issues.apache.org/jira/browse/KAFKA-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15513498#comment-15513498 ] Bill Bejeck commented on KAFKA-4114: Hi Matthias, I've started working on this and wanted to

[jira] [Commented] (KAFKA-4114) Allow for different "auto.offset.reset" strategies for different input streams

[ https://issues.apache.org/jira/browse/KAFKA-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15531675#comment-15531675 ] Bill Bejeck commented on KAFKA-4114: No worries on the response. Thanks for clearing things up. I

[jira] [Updated] (KAFKA-4114) Allow for different "auto.offset.reset" strategies for different input streams

[ https://issues.apache.org/jira/browse/KAFKA-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-4114: --- Status: Patch Available (was: In Progress) > Allow for different "auto.offset.reset" strategies for

[jira] [Commented] (KAFKA-4114) Allow for different "auto.offset.reset" strategies for different input streams

[ https://issues.apache.org/jira/browse/KAFKA-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15564050#comment-15564050 ] Bill Bejeck commented on KAFKA-4114: Fair enough doing so now. > Allow for different

[jira] [Assigned] (KAFKA-4312) void KTableImpl.writeAsText(String filePath) throws NullPointerException when filePath is empty String

[ https://issues.apache.org/jira/browse/KAFKA-4312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-4312: -- Assignee: Bill Bejeck > void KTableImpl.writeAsText(String filePath) throws

[jira] [Work started] (KAFKA-4312) void KTableImpl.writeAsText(String filePath) throws NullPointerException when filePath is empty String

[ https://issues.apache.org/jira/browse/KAFKA-4312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4312 started by Bill Bejeck. -- > void KTableImpl.writeAsText(String filePath) throws NullPointerException when >

[jira] [Updated] (KAFKA-4312) void KTableImpl.writeAsText(String filePath) throws NullPointerException when filePath is empty String

[ https://issues.apache.org/jira/browse/KAFKA-4312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-4312: --- Component/s: streams > void KTableImpl.writeAsText(String filePath) throws NullPointerException when

[jira] [Updated] (KAFKA-4312) void KTableImpl.writeAsText(String filePath) throws NullPointerException when filePath is empty String

[ https://issues.apache.org/jira/browse/KAFKA-4312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-4312: --- Fix Version/s: 0.10.1.1 Status: Patch Available (was: In Progress) > void

[jira] [Updated] (KAFKA-4269) Multiple KStream instances with at least one Regex source causes NPE when using multiple consumers

[ https://issues.apache.org/jira/browse/KAFKA-4269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-4269: --- Fix Version/s: 0.10.1.0 Status: Patch Available (was: In Progress) > Multiple KStream

[jira] [Commented] (KAFKA-4114) Allow for different "auto.offset.reset" strategies for different input streams

[ https://issues.apache.org/jira/browse/KAFKA-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15563934#comment-15563934 ] Bill Bejeck commented on KAFKA-4114: I have a working solution, just waiting for resolution to

[jira] [Work started] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4468 started by Bill Bejeck. -- > Correctly calculate the window end timestamp after read from state stores >

[jira] [Commented] (KAFKA-4125) Provide low-level Processor API meta data in DSL layer

[ https://issues.apache.org/jira/browse/KAFKA-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15822833#comment-15822833 ] Bill Bejeck commented on KAFKA-4125: [~mjsax] - Sounds reasonable to me. With the information you

[jira] [Commented] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15707119#comment-15707119 ] Bill Bejeck commented on KAFKA-4468: Picking this one up. > Correctly calculate the window end

[jira] [Assigned] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-4468: -- Assignee: Bill Bejeck > Correctly calculate the window end timestamp after read from state

[jira] [Commented] (KAFKA-4601) Avoid duplicated repartitioning in KStream DSL

[ https://issues.apache.org/jira/browse/KAFKA-4601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802932#comment-15802932 ] Bill Bejeck commented on KAFKA-4601: Thanks for the explanation. Avoiding duplicated partitioning

[jira] [Work stopped] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4468 stopped by Bill Bejeck. -- > Correctly calculate the window end timestamp after read from state stores >

[jira] [Updated] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-4468: --- Assignee: (was: Bill Bejeck) > Correctly calculate the window end timestamp after read from state

[jira] [Assigned] (KAFKA-4601) Avoid duplicated repartitioning in KStream DSL

[ https://issues.apache.org/jira/browse/KAFKA-4601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-4601: -- Assignee: Bill Bejeck > Avoid duplicated repartitioning in KStream DSL >

[jira] [Commented] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15783884#comment-15783884 ] Bill Bejeck commented on KAFKA-4468: Yes, that makes sense. I misinterpreted the requirements and

[jira] [Commented] (KAFKA-4601) Avoid duplicated repartitioning in KStream DSL

[ https://issues.apache.org/jira/browse/KAFKA-4601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802878#comment-15802878 ] Bill Bejeck commented on KAFKA-4601: If it's ok, picking this one up. > Avoid duplicated

[jira] [Updated] (KAFKA-4601) Avoid duplicated repartitioning in KStream DSL

[ https://issues.apache.org/jira/browse/KAFKA-4601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-4601: --- Assignee: (was: Bill Bejeck) > Avoid duplicated repartitioning in KStream DSL >

[jira] [Commented] (KAFKA-4125) Provide low-level Processor API meta data in DSL layer

[ https://issues.apache.org/jira/browse/KAFKA-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15812586#comment-15812586 ] Bill Bejeck commented on KAFKA-4125: Is this task still viable/desired? If so I'll pick it up. >

[jira] [Commented] (KAFKA-4125) Provide low-level Processor API meta data in DSL layer

[ https://issues.apache.org/jira/browse/KAFKA-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815003#comment-15815003 ] Bill Bejeck commented on KAFKA-4125: [~guozhang] [~mjsax] Thanks for the response. Sure I'll give

[jira] [Commented] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15730787#comment-15730787 ] Bill Bejeck commented on KAFKA-4468: Unless I'm missing something, this task implies we'll need to

[jira] [Resolved] (KAFKA-4868) Optimize RocksDb config for fast recovery/bulk load

[ https://issues.apache.org/jira/browse/KAFKA-4868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-4868. Resolution: Fixed resolved with merge of KIP-167 > Optimize RocksDb config for fast recovery/bulk

[jira] [Created] (KAFKA-5711) Bulk Restore Should Handle Deletes

Bill Bejeck created KAFKA-5711: -- Summary: Bulk Restore Should Handle Deletes Key: KAFKA-5711 URL: https://issues.apache.org/jira/browse/KAFKA-5711 Project: Kafka Issue Type: Bug

[jira] [Assigned] (KAFKA-5226) NullPointerException (NPE) in SourceNodeRecordDeserializer.deserialize

[ https://issues.apache.org/jira/browse/KAFKA-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-5226: -- Assignee: Bill Bejeck (was: Matthias J. Sax) > NullPointerException (NPE) in

[jira] [Created] (KAFKA-5493) Optimize calls to flush for tasks and standby tasks

Bill Bejeck created KAFKA-5493: -- Summary: Optimize calls to flush for tasks and standby tasks Key: KAFKA-5493 URL: https://issues.apache.org/jira/browse/KAFKA-5493 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-5515) Consider removing date formatting from Segments class

Bill Bejeck created KAFKA-5515: -- Summary: Consider removing date formatting from Segments class Key: KAFKA-5515 URL: https://issues.apache.org/jira/browse/KAFKA-5515 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-5226) NullPointerException (NPE) in SourceNodeRecordDeserializer.deserialize

[ https://issues.apache.org/jira/browse/KAFKA-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-5226: --- Fix Version/s: 0.11.0.0 > NullPointerException (NPE) in SourceNodeRecordDeserializer.deserialize >

[jira] [Updated] (KAFKA-5226) NullPointerException (NPE) in SourceNodeRecordDeserializer.deserialize

[ https://issues.apache.org/jira/browse/KAFKA-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-5226: --- Status: Patch Available (was: In Progress) > NullPointerException (NPE) in

[jira] [Updated] (KAFKA-5226) NullPointerException (NPE) in SourceNodeRecordDeserializer.deserialize

[ https://issues.apache.org/jira/browse/KAFKA-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-5226: --- Attachment: streamsAppTwo.log streamsAppThree.log streamsAppOne.log >

[jira] [Commented] (KAFKA-5226) NullPointerException (NPE) in SourceNodeRecordDeserializer.deserialize

[ https://issues.apache.org/jira/browse/KAFKA-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16025404#comment-16025404 ] Bill Bejeck commented on KAFKA-5226: I've been able to reproduce the problem. The issue is not with

[jira] [Work started] (KAFKA-5226) NullPointerException (NPE) in SourceNodeRecordDeserializer.deserialize

[ https://issues.apache.org/jira/browse/KAFKA-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5226 started by Bill Bejeck. -- > NullPointerException (NPE) in SourceNodeRecordDeserializer.deserialize >

[jira] [Updated] (KAFKA-5363) Add ability to batch restore and receive restoration stats.

[ https://issues.apache.org/jira/browse/KAFKA-5363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-5363: --- Summary: Add ability to batch restore and receive restoration stats. (was: Add restoreAll

[jira] [Updated] (KAFKA-5363) Add ability to batch restore and receive restoration stats.

[ https://issues.apache.org/jira/browse/KAFKA-5363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-5363: --- Description: Currently, when restoring a state store in a Kafka Streams application, we put one

[jira] [Created] (KAFKA-5363) Add restoreAll functionality to StateRestoreCallback

Bill Bejeck created KAFKA-5363: -- Summary: Add restoreAll functionality to StateRestoreCallback Key: KAFKA-5363 URL: https://issues.apache.org/jira/browse/KAFKA-5363 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-5363) Add restoreAll functionality to StateRestoreCallback

[ https://issues.apache.org/jira/browse/KAFKA-5363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-5363: --- Description: Add a new method {{restoreAll(KeyValue records)}} to the

[jira] [Updated] (KAFKA-5363) Add restoreAll functionality to StateRestoreCallback

[ https://issues.apache.org/jira/browse/KAFKA-5363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-5363: --- Description: Add a new method {{restoreAll(List> records)}} to the

[jira] [Updated] (KAFKA-5363) Add restoreAll functionality to StateRestoreCallback

[ https://issues.apache.org/jira/browse/KAFKA-5363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-5363: --- Description: Add a new method {{restoreAll(KeyValue records)}} to the

[jira] [Updated] (KAFKA-5363) Add ability to batch restore and receive restoration stats.

[ https://issues.apache.org/jira/browse/KAFKA-5363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-5363: --- Description: Currently, when restoring a state store in a Kafka Streams application, we put one

[jira] [Updated] (KAFKA-4868) Optimize RocksDb config for fast recovery/bulk load

[ https://issues.apache.org/jira/browse/KAFKA-4868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-4868: --- Issue Type: Sub-task (was: Improvement) Parent: KAFKA-5363 > Optimize RocksDb config for

[jira] [Work started] (KAFKA-5363) Add ability to batch restore and receive restoration stats.

[ https://issues.apache.org/jira/browse/KAFKA-5363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5363 started by Bill Bejeck. -- > Add ability to batch restore and receive restoration stats. >

[jira] [Work started] (KAFKA-4868) Optimize RocksDb config for fast recovery/bulk load

[ https://issues.apache.org/jira/browse/KAFKA-4868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4868 started by Bill Bejeck. -- > Optimize RocksDb config for fast recovery/bulk load >

[jira] [Updated] (KAFKA-5226) NullPointerException (NPE) in SourceNodeRecordDeserializer.deserialize

[ https://issues.apache.org/jira/browse/KAFKA-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-5226: --- Fix Version/s: (was: 0.11.0.0) 0.11.0.1 > NullPointerException (NPE) in

[jira] [Created] (KAFKA-5965) Remove Deprecated AdminClient from Streams Resetter Tool

Bill Bejeck created KAFKA-5965: -- Summary: Remove Deprecated AdminClient from Streams Resetter Tool Key: KAFKA-5965 URL: https://issues.apache.org/jira/browse/KAFKA-5965 Project: Kafka Issue

[jira] [Created] (KAFKA-6364) Add Second Check for End Offset During Restore

Bill Bejeck created KAFKA-6364: -- Summary: Add Second Check for End Offset During Restore Key: KAFKA-6364 URL: https://issues.apache.org/jira/browse/KAFKA-6364 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-6367) Fix StateRestoreListener To Use Correct Ending Offset

Bill Bejeck created KAFKA-6367: -- Summary: Fix StateRestoreListener To Use Correct Ending Offset Key: KAFKA-6367 URL: https://issues.apache.org/jira/browse/KAFKA-6367 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-6373) Log end offset of input table changing during restore

[ https://issues.apache.org/jira/browse/KAFKA-6373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-6373. Resolution: Duplicate Duplicate issue of KAFKA-6269 > Log end offset of input table changing

[jira] [Created] (KAFKA-6205) Have State Stores Restore Before Initializing Toplogy

Bill Bejeck created KAFKA-6205: -- Summary: Have State Stores Restore Before Initializing Toplogy Key: KAFKA-6205 URL: https://issues.apache.org/jira/browse/KAFKA-6205 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-6874) Add Configuration Allowing for Optional Topology Optimization

Bill Bejeck created KAFKA-6874: -- Summary: Add Configuration Allowing for Optional Topology Optimization Key: KAFKA-6874 URL: https://issues.apache.org/jira/browse/KAFKA-6874 Project: Kafka

[jira] [Created] (KAFKA-6935) KIP-295 Add Streams Config for Optional Optimization

Bill Bejeck created KAFKA-6935: -- Summary: KIP-295 Add Streams Config for Optional Optimization Key: KAFKA-6935 URL: https://issues.apache.org/jira/browse/KAFKA-6935 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-7027) Overloaded StreamsBuilder Build Method to Accept java.util.Properties

Bill Bejeck created KAFKA-7027: -- Summary: Overloaded StreamsBuilder Build Method to Accept java.util.Properties Key: KAFKA-7027 URL: https://issues.apache.org/jira/browse/KAFKA-7027 Project: Kafka

[jira] [Created] (KAFKA-6964) Add ability to print all internal topic names

Bill Bejeck created KAFKA-6964: -- Summary: Add ability to print all internal topic names Key: KAFKA-6964 URL: https://issues.apache.org/jira/browse/KAFKA-6964 Project: Kafka Issue Type: New

[jira] [Created] (KAFKA-6844) Race condition between StreamThread and GlobalStreamThread stopping

Bill Bejeck created KAFKA-6844: -- Summary: Race condition between StreamThread and GlobalStreamThread stopping Key: KAFKA-6844 URL: https://issues.apache.org/jira/browse/KAFKA-6844 Project: Kafka

[jira] [Created] (KAFKA-6411) Update KStream javadoc examples to use new StateStore API

Bill Bejeck created KAFKA-6411: -- Summary: Update KStream javadoc examples to use new StateStore API Key: KAFKA-6411 URL: https://issues.apache.org/jira/browse/KAFKA-6411 Project: Kafka Issue

[jira] [Created] (KAFKA-6487) ChangeLoggingKeyValueBytesStore.all() returns null

Bill Bejeck created KAFKA-6487: -- Summary: ChangeLoggingKeyValueBytesStore.all() returns null Key: KAFKA-6487 URL: https://issues.apache.org/jira/browse/KAFKA-6487 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-6508) Look into optimizing StreamPartitionAssignor StandbyTask Assignment

Bill Bejeck created KAFKA-6508: -- Summary: Look into optimizing StreamPartitionAssignor StandbyTask Assignment Key: KAFKA-6508 URL: https://issues.apache.org/jira/browse/KAFKA-6508 Project: Kafka

[jira] [Created] (KAFKA-6509) Add additional tests for validating store restoration completes before Topology is intitalized

Bill Bejeck created KAFKA-6509: -- Summary: Add additional tests for validating store restoration completes before Topology is intitalized Key: KAFKA-6509 URL: https://issues.apache.org/jira/browse/KAFKA-6509

[jira] [Created] (KAFKA-7221) Add Build method to StreamsBuilder accepting Properties

Bill Bejeck created KAFKA-7221: -- Summary: Add Build method to StreamsBuilder accepting Properties Key: KAFKA-7221 URL: https://issues.apache.org/jira/browse/KAFKA-7221 Project: Kafka Issue

[jira] [Resolved] (KAFKA-7221) Add Build method to StreamsBuilder accepting Properties

[ https://issues.apache.org/jira/browse/KAFKA-7221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-7221. Resolution: Fixed Duplicated by KAFKA-7027 > Add Build method to StreamsBuilder accepting

[jira] [Created] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

Bill Bejeck created KAFKA-7190: -- Summary: Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID Key: KAFKA-7190 URL:

[jira] [Created] (KAFKA-7200) Preserve serdes used

Bill Bejeck created KAFKA-7200: -- Summary: Preserve serdes used Key: KAFKA-7200 URL: https://issues.apache.org/jira/browse/KAFKA-7200 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-7201) Optimize repartition operations

Bill Bejeck created KAFKA-7201: -- Summary: Optimize repartition operations Key: KAFKA-7201 URL: https://issues.apache.org/jira/browse/KAFKA-7201 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-7198) Enhance KafkaStreams start method javadoc

Bill Bejeck created KAFKA-7198: -- Summary: Enhance KafkaStreams start method javadoc Key: KAFKA-7198 URL: https://issues.apache.org/jira/browse/KAFKA-7198 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-6761) Reduce Kafka Streams Footprint

Bill Bejeck created KAFKA-6761: -- Summary: Reduce Kafka Streams Footprint Key: KAFKA-6761 URL: https://issues.apache.org/jira/browse/KAFKA-6761 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-6802) Improve logging when topics aren't known and assignments skipped

Bill Bejeck created KAFKA-6802: -- Summary: Improve logging when topics aren't known and assignments skipped Key: KAFKA-6802 URL: https://issues.apache.org/jira/browse/KAFKA-6802 Project: Kafka

[jira] [Created] (KAFKA-6704) Checking hasNext from SegementIterator could throw InvalidStateStoreException

Bill Bejeck created KAFKA-6704: -- Summary: Checking hasNext from SegementIterator could throw InvalidStateStoreException Key: KAFKA-6704 URL: https://issues.apache.org/jira/browse/KAFKA-6704 Project:

[jira] [Created] (KAFKA-6708) Review JavaDocs and Documentation with regards to Serde Useage

Bill Bejeck created KAFKA-6708: -- Summary: Review JavaDocs and Documentation with regards to Serde Useage Key: KAFKA-6708 URL: https://issues.apache.org/jira/browse/KAFKA-6708 Project: Kafka

[jira] [Created] (KAFKA-6829) Consumer should retry when encountering unknown topic or partition error

Bill Bejeck created KAFKA-6829: -- Summary: Consumer should retry when encountering unknown topic or partition error Key: KAFKA-6829 URL: https://issues.apache.org/jira/browse/KAFKA-6829 Project: Kafka

[jira] [Created] (KAFKA-7534) Error during CachingKeyValueStore.flush may not allow RocksDB to close

Bill Bejeck created KAFKA-7534: -- Summary: Error during CachingKeyValueStore.flush may not allow RocksDB to close Key: KAFKA-7534 URL: https://issues.apache.org/jira/browse/KAFKA-7534 Project: Kafka

[jira] [Resolved] (KAFKA-7552) StatefulProcessorNode tries to connect state store to processor before it is added

[ https://issues.apache.org/jira/browse/KAFKA-7552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-7552. Resolution: Fixed Fixed with PR 

[jira] [Resolved] (KAFKA-4601) Avoid duplicated repartitioning in KStream DSL

[ https://issues.apache.org/jira/browse/KAFKA-4601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-4601. Resolution: Fixed Marking this resolved with [https://github.com/apache/kafka/pull/5451.] As 

[jira] [Created] (KAFKA-7758) When Naming a Repartition Topic with Aggregations Reuse Repartition Graph Node for Multiple Operations

Bill Bejeck created KAFKA-7758: -- Summary: When Naming a Repartition Topic with Aggregations Reuse Repartition Graph Node for Multiple Operations Key: KAFKA-7758 URL: https://issues.apache.org/jira/browse/KAFKA-7758

[jira] [Created] (KAFKA-7406) Naming Join and Grouping Operations

Bill Bejeck created KAFKA-7406: -- Summary: Naming Join and Grouping Operations Key: KAFKA-7406 URL: https://issues.apache.org/jira/browse/KAFKA-7406 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-6399) Consider reducing "max.poll.interval.ms" default for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-6399. Resolution: Fixed > Consider reducing "max.poll.interval.ms" default for Kafka Streams >

[jira] [Created] (KAFKA-8199) ClassCastException when trying to groupBy after suppress

Bill Bejeck created KAFKA-8199: -- Summary: ClassCastException when trying to groupBy after suppress Key: KAFKA-8199 URL: https://issues.apache.org/jira/browse/KAFKA-8199 Project: Kafka Issue

[jira] [Created] (KAFKA-8011) Flaky Test RegexSourceIntegrationTest.

Bill Bejeck created KAFKA-8011: -- Summary: Flaky Test RegexSourceIntegrationTest. Key: KAFKA-8011 URL: https://issues.apache.org/jira/browse/KAFKA-8011 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-7963) Extract hard-coded Streams metric name strings to centralized place

[ https://issues.apache.org/jira/browse/KAFKA-7963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-7963. Resolution: Fixed > Extract hard-coded Streams metric name strings to centralized place >

[jira] [Resolved] (KAFKA-7492) Explain `null` handling for reduce and aggregate

[ https://issues.apache.org/jira/browse/KAFKA-7492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-7492. Resolution: Fixed Thanks asutosh for the contribution! > Explain `null` handling for reduce and

[jira] [Created] (KAFKA-8045) Possible Flaky Test LogOffsetTest.testGetOffsetsBeforeNow

Bill Bejeck created KAFKA-8045: -- Summary: Possible Flaky Test LogOffsetTest.testGetOffsetsBeforeNow Key: KAFKA-8045 URL: https://issues.apache.org/jira/browse/KAFKA-8045 Project: Kafka Issue

[jira] [Created] (KAFKA-8101) Optimization Has Different Processor Node Count on Scala API

Bill Bejeck created KAFKA-8101: -- Summary: Optimization Has Different Processor Node Count on Scala API Key: KAFKA-8101 URL: https://issues.apache.org/jira/browse/KAFKA-8101 Project: Kafka

[jira] [Created] (KAFKA-8072) Transient failure in SslSelectorTest.testCloseOldestConnectionWithMultipleStagedReceives

Bill Bejeck created KAFKA-8072: -- Summary: Transient failure in SslSelectorTest.testCloseOldestConnectionWithMultipleStagedReceives Key: KAFKA-8072 URL: https://issues.apache.org/jira/browse/KAFKA-8072

[jira] [Reopened] (KAFKA-7980) Flaky Test SocketServerTest#testConnectionRateLimit

[ https://issues.apache.org/jira/browse/KAFKA-7980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reopened KAFKA-7980: Assignee: (was: Rajini Sivaram) Failed again in build

[jira] [Resolved] (KAFKA-7980) Flaky Test SocketServerTest#testConnectionRateLimit

[ https://issues.apache.org/jira/browse/KAFKA-7980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-7980. Resolution: Fixed Resolving this as the PR build was started before the fix for this test was

[jira] [Resolved] (KAFKA-8040) Streams needs to retry initTransactions

[ https://issues.apache.org/jira/browse/KAFKA-8040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8040. Resolution: Fixed > Streams needs to retry initTransactions >

[jira] [Created] (KAFKA-8073) Transient failure in kafka.api.UserQuotaTest.testThrottledProducerConsumer

Bill Bejeck created KAFKA-8073: -- Summary: Transient failure in kafka.api.UserQuotaTest.testThrottledProducerConsumer Key: KAFKA-8073 URL: https://issues.apache.org/jira/browse/KAFKA-8073 Project: Kafka

[jira] [Resolved] (KAFKA-8094) Iterating over cache with get(key) is inefficient

[ https://issues.apache.org/jira/browse/KAFKA-8094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8094. Resolution: Fixed > Iterating over cache with get(key) is inefficient >

<    1   2   3   4   >