[jira] [Comment Edited] (KAFKA-8877) Race condition on partition counter

2019-09-05 Thread Oleg Kuznetsov (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923379#comment-16923379 ] Oleg Kuznetsov edited comment on KAFKA-8877 at 9/5/19 12:36 PM: ---

[jira] [Commented] (KAFKA-8877) Race condition on partition counter

2019-09-05 Thread Oleg Kuznetsov (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923379#comment-16923379 ] Oleg Kuznetsov commented on KAFKA-8877: --- [~huxi_2b] Yes, you are right.   But lo

[jira] [Updated] (KAFKA-8877) Race condition on partition counter

2019-09-05 Thread Oleg Kuznetsov (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleg Kuznetsov updated KAFKA-8877: -- Description: In the method: *org.apache.kafka.clients.producer.internals.DefaultPartitioner#ne

[jira] [Updated] (KAFKA-8877) Race condition on partition counter

2019-09-05 Thread Oleg Kuznetsov (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleg Kuznetsov updated KAFKA-8877: -- Description: In the method: *org.apache.kafka.clients.producer.internals.DefaultPartitioner#ne

[jira] [Created] (KAFKA-8877) Race condition on partition counter

2019-09-05 Thread Oleg Kuznetsov (Jira)
Oleg Kuznetsov created KAFKA-8877: - Summary: Race condition on partition counter Key: KAFKA-8877 URL: https://issues.apache.org/jira/browse/KAFKA-8877 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-7263) Container exception java.lang.IllegalStateException: Coordinator selected invalid assignment protocol: null

2019-08-13 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16906464#comment-16906464 ] Oleg Kuznetsov commented on KAFKA-7263: --- [~mjsax] Do you happen to have a workaroun

[jira] [Commented] (KAFKA-2480) Handle non-CopycatExceptions from SinkTasks

2019-03-18 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16794970#comment-16794970 ] Oleg Kuznetsov commented on KAFKA-2480: --- Then a lot of open source connectors misus

[jira] [Commented] (KAFKA-2480) Handle non-CopycatExceptions from SinkTasks

2019-03-17 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16794616#comment-16794616 ] Oleg Kuznetsov commented on KAFKA-2480: --- [~ewencp] I was talking about sink connec

[jira] [Commented] (KAFKA-2480) Handle non-CopycatExceptions from SinkTasks

2019-03-17 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16794524#comment-16794524 ] Oleg Kuznetsov commented on KAFKA-2480: --- [~gwenshap] [~ewencp] Looks like the way i

[jira] [Comment Edited] (KAFKA-7593) Infinite restart loop when failed to store big config for task

2018-11-06 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16677704#comment-16677704 ] Oleg Kuznetsov edited comment on KAFKA-7593 at 11/7/18 5:27 AM: ---

[jira] [Commented] (KAFKA-7593) Infinite restart loop when failed to store big config for task

2018-11-06 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16677704#comment-16677704 ] Oleg Kuznetsov commented on KAFKA-7593: --- [~rhauch] Sure, workaround is clear, but t

[jira] [Comment Edited] (KAFKA-7593) Infinite restart loop when failed to store big config for task

2018-11-06 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16677704#comment-16677704 ] Oleg Kuznetsov edited comment on KAFKA-7593 at 11/7/18 5:23 AM: ---

[jira] [Created] (KAFKA-7593) Infinite restart loop when failed to store big config for task

2018-11-05 Thread Oleg Kuznetsov (JIRA)
Oleg Kuznetsov created KAFKA-7593: - Summary: Infinite restart loop when failed to store big config for task Key: KAFKA-7593 URL: https://issues.apache.org/jira/browse/KAFKA-7593 Project: Kafka

[jira] [Updated] (KAFKA-7404) SourceConnector backpressure

2018-09-11 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleg Kuznetsov updated KAFKA-7404: -- Description: Now Source connector can generate lots of events without considering how fast bro

[jira] [Created] (KAFKA-7404) SourceConnector backpressure

2018-09-11 Thread Oleg Kuznetsov (JIRA)
Oleg Kuznetsov created KAFKA-7404: - Summary: SourceConnector backpressure Key: KAFKA-7404 URL: https://issues.apache.org/jira/browse/KAFKA-7404 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-6891) send.buffer.bytes should be allowed to set -1 in KafkaConnect

2018-05-12 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16473103#comment-16473103 ] Oleg Kuznetsov commented on KAFKA-6891: --- [~ewencp] could you review please? > send.

[jira] [Commented] (KAFKA-6891) send.buffer.bytes should be allowed to set -1 in KafkaConnect

2018-05-10 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16470066#comment-16470066 ] Oleg Kuznetsov commented on KAFKA-6891: --- https://github.com/apache/kafka/pull/4995

[jira] [Commented] (KAFKA-6891) send.buffer.bytes should be allowed to set -1 in KafkaConnect

2018-05-09 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469797#comment-16469797 ] Oleg Kuznetsov commented on KAFKA-6891: --- [~ewencp] Great, let me do that. > send.bu

[jira] [Commented] (KAFKA-6891) send.buffer.bytes should be allowed to set -1 in KafkaConnect

2018-05-09 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469621#comment-16469621 ] Oleg Kuznetsov commented on KAFKA-6891: --- [~ewencp] Do you agree? > send.buffer.byte

[jira] [Updated] (KAFKA-6891) send.buffer.bytes should be allowed to set -1 in KafkaConnect

2018-05-09 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleg Kuznetsov updated KAFKA-6891: -- Description: *send.buffer.bytes* and *receive.buffer.bytes* are declared with *atLeast(0)* const

[jira] [Created] (KAFKA-6891) send.buffer.bytes should be allowed to set -1 in KafkaConnect

2018-05-09 Thread Oleg Kuznetsov (JIRA)
Oleg Kuznetsov created KAFKA-6891: - Summary: send.buffer.bytes should be allowed to set -1 in KafkaConnect Key: KAFKA-6891 URL: https://issues.apache.org/jira/browse/KAFKA-6891 Project: Kafka

[jira] [Updated] (KAFKA-6869) Distributed herder synchronization issue

2018-05-05 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleg Kuznetsov updated KAFKA-6869: -- Description: {code:java} org.apache.kafka.connect.runtime.distributed.DistributedHerder#needsRec

[jira] [Updated] (KAFKA-6869) Distributed herder synchronization issue

2018-05-05 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleg Kuznetsov updated KAFKA-6869: -- Description: {code}org.apache.kafka.connect.runtime.distributed.DistributedHerder#needsReconfigR

[jira] [Created] (KAFKA-6869) Distributed herder synchronization issue

2018-05-05 Thread Oleg Kuznetsov (JIRA)
Oleg Kuznetsov created KAFKA-6869: - Summary: Distributed herder synchronization issue Key: KAFKA-6869 URL: https://issues.apache.org/jira/browse/KAFKA-6869 Project: Kafka Issue Type: Bug

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

2018-01-28 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16342510#comment-16342510 ] Oleg Kuznetsov commented on KAFKA-4794: --- [~rhauch] Is it scheduled on release 1.1.0?

[jira] [Created] (KAFKA-6340) Support of transactions in KafkaConnect

2017-12-09 Thread Oleg Kuznetsov (JIRA)
Oleg Kuznetsov created KAFKA-6340: - Summary: Support of transactions in KafkaConnect Key: KAFKA-6340 URL: https://issues.apache.org/jira/browse/KAFKA-6340 Project: Kafka Issue Type: Improveme

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

2017-10-06 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16194836#comment-16194836 ] Oleg Kuznetsov commented on KAFKA-4794: --- You mentioned that connector cannot read of

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

2017-10-06 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16194828#comment-16194828 ] Oleg Kuznetsov commented on KAFKA-4794: --- [~rhauch] could you describe how the descri

[jira] [Created] (KAFKA-5866) Let source/sink task to finish their job before exit

2017-09-10 Thread Oleg Kuznetsov (JIRA)
Oleg Kuznetsov created KAFKA-5866: - Summary: Let source/sink task to finish their job before exit Key: KAFKA-5866 URL: https://issues.apache.org/jira/browse/KAFKA-5866 Project: Kafka Issue Ty

[jira] [Commented] (KAFKA-5696) SourceConnector does not commit offset on rebalance

2017-09-08 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16159394#comment-16159394 ] Oleg Kuznetsov commented on KAFKA-5696: --- [~Yohan123] I see that configuration change

[jira] [Commented] (KAFKA-5696) SourceConnector does not commit offset on rebalance

2017-08-23 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16139481#comment-16139481 ] Oleg Kuznetsov commented on KAFKA-5696: --- [~Yohan123] Main issue was not resolved - w

[jira] [Comment Edited] (KAFKA-5696) SourceConnector does not commit offset on rebalance

2017-08-22 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137100#comment-16137100 ] Oleg Kuznetsov edited comment on KAFKA-5696 at 8/22/17 5:56 PM:

[jira] [Commented] (KAFKA-5696) SourceConnector does not commit offset on rebalance

2017-08-22 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137100#comment-16137100 ] Oleg Kuznetsov commented on KAFKA-5696: --- [~rhauch] Is it possible to add waiting all

[jira] [Commented] (KAFKA-5696) SourceConnector does not commit offset on rebalance

2017-08-21 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16134997#comment-16134997 ] Oleg Kuznetsov commented on KAFKA-5696: --- [~rhauch] Is it possible that config update

[jira] [Commented] (KAFKA-5756) Synchronization issue on flush

2017-08-20 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16134575#comment-16134575 ] Oleg Kuznetsov commented on KAFKA-5756: --- [~ewencp] [~rhauch] Could you take a look?

[jira] [Updated] (KAFKA-5756) Synchronization issue on flush

2017-08-20 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleg Kuznetsov updated KAFKA-5756: -- Description: Access to *OffsetStorageWriter#toFlush* is not synchronized in *doFlush()* method,

[jira] [Updated] (KAFKA-5756) Synchronization issue on flush

2017-08-20 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleg Kuznetsov updated KAFKA-5756: -- Description: Access to *OffsetStorageWriter#toFlush* is not synchronized in *doFlush()* method,

[jira] [Created] (KAFKA-5756) Synchronization issue on flush

2017-08-20 Thread Oleg Kuznetsov (JIRA)
Oleg Kuznetsov created KAFKA-5756: - Summary: Synchronization issue on flush Key: KAFKA-5756 URL: https://issues.apache.org/jira/browse/KAFKA-5756 Project: Kafka Issue Type: Bug Comp

[jira] [Commented] (KAFKA-5696) SourceConnector does not commit offset on rebalance

2017-08-16 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16129105#comment-16129105 ] Oleg Kuznetsov commented on KAFKA-5696: --- [~rhauch] I believe yes, finally block is n

[jira] [Commented] (KAFKA-5696) SourceConnector does not commit offset on rebalance

2017-08-07 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16117301#comment-16117301 ] Oleg Kuznetsov commented on KAFKA-5696: --- Yes, you are right. Is there a chance tha

[jira] [Commented] (KAFKA-5696) SourceConnector does not commit offset on rebalance

2017-08-07 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16116962#comment-16116962 ] Oleg Kuznetsov commented on KAFKA-5696: --- [~rhauch] Thank you for detailed explanatio

[jira] [Commented] (KAFKA-5696) SourceConnector does not commit offset on reconfiguration

2017-08-04 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16115041#comment-16115041 ] Oleg Kuznetsov commented on KAFKA-5696: --- Is it true that there is a chance of produc

[jira] [Commented] (KAFKA-5696) SourceConnector does not commit offset on reconfiguration

2017-08-04 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16114942#comment-16114942 ] Oleg Kuznetsov commented on KAFKA-5696: --- [~rhauch] Thanks. Do you confirm it could b

[jira] [Created] (KAFKA-5696) SourceConnector does not commit offset on reconfiguration

2017-08-03 Thread Oleg Kuznetsov (JIRA)
Oleg Kuznetsov created KAFKA-5696: - Summary: SourceConnector does not commit offset on reconfiguration Key: KAFKA-5696 URL: https://issues.apache.org/jira/browse/KAFKA-5696 Project: Kafka Iss

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

2017-07-17 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16090034#comment-16090034 ] Oleg Kuznetsov commented on KAFKA-4794: --- [~fhussonnois] I meant who could give it?

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

2017-07-16 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16089196#comment-16089196 ] Oleg Kuznetsov edited comment on KAFKA-4794 at 7/17/17 12:07 AM: ---

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

2017-07-16 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16089196#comment-16089196 ] Oleg Kuznetsov commented on KAFKA-4794: --- [~jasong35] Do you have any feedback regard

[jira] [Resolved] (KAFKA-5598) Make OffsetReader accessible in ConnectorContext

2017-07-16 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleg Kuznetsov resolved KAFKA-5598. --- Resolution: Duplicate > Make OffsetReader accessible in ConnectorContext > ---

[jira] [Updated] (KAFKA-5598) Make OffsetReader accessible in ConnectorContext

2017-07-16 Thread Oleg Kuznetsov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleg Kuznetsov updated KAFKA-5598: -- Description: It is useful to read offset in SourceConnector, but now OffsetReader is accessible

[jira] [Created] (KAFKA-5598) Make OffsetReader accessible in ConnectorContext

2017-07-16 Thread Oleg Kuznetsov (JIRA)
Oleg Kuznetsov created KAFKA-5598: - Summary: Make OffsetReader accessible in ConnectorContext Key: KAFKA-5598 URL: https://issues.apache.org/jira/browse/KAFKA-5598 Project: Kafka Issue Type: