[jira] [Created] (KAFKA-6957) Add getter to AbstractStream class to make internalTopologyBuilder accessible outside of package

Florian Hussonnois created KAFKA-6957: - Summary: Add getter to AbstractStream class to make internalTopologyBuilder accessible outside of package Key: KAFKA-6957 URL: https://issues.apache.org/jira/browse/KAFK

[jira] [Created] (KAFKA-6958) Allow to define custom processor names with KStreams DSL

Florian Hussonnois created KAFKA-6958: - Summary: Allow to define custom processor names with KStreams DSL Key: KAFKA-6958 URL: https://issues.apache.org/jira/browse/KAFKA-6958 Project: Kafka

[jira] [Created] (KAFKA-3737) Closing connection during produce request should be log with WARN level.

Florian Hussonnois created KAFKA-3737: - Summary: Closing connection during produce request should be log with WARN level. Key: KAFKA-3737 URL: https://issues.apache.org/jira/browse/KAFKA-3737 Proj

[jira] [Commented] (KAFKA-3737) Closing connection during produce request should be log with WARN level.

[ https://issues.apache.org/jira/browse/KAFKA-3737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15329482#comment-15329482 ] Florian Hussonnois commented on KAFKA-3737: --- Hi Gwen, My concern is more about

[jira] [Created] (KAFKA-3922) Add a copy-constructor to AbstractStream

Florian Hussonnois created KAFKA-3922: - Summary: Add a copy-constructor to AbstractStream Key: KAFKA-3922 URL: https://issues.apache.org/jira/browse/KAFKA-3922 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-4794) Add access to OffsetStorageReader from SourceConnector

Florian Hussonnois created KAFKA-4794: - Summary: Add access to OffsetStorageReader from SourceConnector Key: KAFKA-4794 URL: https://issues.apache.org/jira/browse/KAFKA-4794 Project: Kafka

[jira] [Updated] (KAFKA-4794) Add access to OffsetStorageReader from SourceConnector

[ https://issues.apache.org/jira/browse/KAFKA-4794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Hussonnois updated KAFKA-4794: -- Affects Version/s: 0.10.2.0 > Add access to OffsetStorageReader from SourceConnector > -

[jira] [Created] (KAFKA-4819) Expose states of active tasks to public API

Florian Hussonnois created KAFKA-4819: - Summary: Expose states of active tasks to public API Key: KAFKA-4819 URL: https://issues.apache.org/jira/browse/KAFKA-4819 Project: Kafka Issue Typ

[jira] [Created] (KAFKA-4905) StreamPartitionAssignor doesn't respect subscriptions to asisgn partitions.

Florian Hussonnois created KAFKA-4905: - Summary: StreamPartitionAssignor doesn't respect subscriptions to asisgn partitions. Key: KAFKA-4905 URL: https://issues.apache.org/jira/browse/KAFKA-4905 P

[jira] [Updated] (KAFKA-4905) StreamPartitionAssignor doesn't respect subscriptions to assign partitions.

[ https://issues.apache.org/jira/browse/KAFKA-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Hussonnois updated KAFKA-4905: -- Summary: StreamPartitionAssignor doesn't respect subscriptions to assign partitions. (w

[jira] [Commented] (KAFKA-4905) StreamPartitionAssignor doesn't respect subscriptions to assign partitions.

[ https://issues.apache.org/jira/browse/KAFKA-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927100#comment-15927100 ] Florian Hussonnois commented on KAFKA-4905: --- Hi [~mjsax], I'm sorry if my explan

[jira] [Created] (KAFKA-3496) Add policies to reconnection

Florian Hussonnois created KAFKA-3496: - Summary: Add policies to reconnection Key: KAFKA-3496 URL: https://issues.apache.org/jira/browse/KAFKA-3496 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-3496) Add reconnect attemps policies for client

[ https://issues.apache.org/jira/browse/KAFKA-3496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Hussonnois updated KAFKA-3496: -- Summary: Add reconnect attemps policies for client (was: Add policies to reconnection)

[jira] [Created] (KAFKA-2998) New Consumer should not retry indefinitely if no broker is available

Florian Hussonnois created KAFKA-2998: - Summary: New Consumer should not retry indefinitely if no broker is available Key: KAFKA-2998 URL: https://issues.apache.org/jira/browse/KAFKA-2998 Project:

[jira] [Created] (KAFKA-3340) Add support for rebalance and adding concurrently records with MockConsumer

Florian Hussonnois created KAFKA-3340: - Summary: Add support for rebalance and adding concurrently records with MockConsumer Key: KAFKA-3340 URL: https://issues.apache.org/jira/browse/KAFKA-3340 P

[jira] [Created] (KAFKA-4106) Consumer / add configure method to PartitionAssignor interface

Florian Hussonnois created KAFKA-4106: - Summary: Consumer / add configure method to PartitionAssignor interface Key: KAFKA-4106 URL: https://issues.apache.org/jira/browse/KAFKA-4106 Project: Kafka

[jira] [Commented] (KAFKA-4106) Consumer / add configure method to PartitionAssignor interface

[ https://issues.apache.org/jira/browse/KAFKA-4106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15454817#comment-15454817 ] Florian Hussonnois commented on KAFKA-4106: --- Thank you very much, sorry to have

[jira] [Commented] (KAFKA-3340) Add support for rebalance and adding concurrently records with MockConsumer

[ https://issues.apache.org/jira/browse/KAFKA-3340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15459658#comment-15459658 ] Florian Hussonnois commented on KAFKA-3340: --- I have updated a pull request for t

[jira] [Created] (KAFKA-18962) StateRestoreListener onBatchRestored method is called with the totalRestored on GlobalStateStore reprocess

Florian Hussonnois created KAFKA-18962: -- Summary: StateRestoreListener onBatchRestored method is called with the totalRestored on GlobalStateStore reprocess Key: KAFKA-18962 URL: https://issues.apache.org/jir