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

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

[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

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

[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16189082#comment-16189082 ] Apurva Mehta commented on KAFKA-6003: - Unfortunately, I don't think there is an ETA for 0.11.0.2 at

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

[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16189026#comment-16189026 ] Stanislav Chizhov commented on KAFKA-6003: -- Are there any expectation of when 0.11.0.2 is coming

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

[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16189022#comment-16189022 ] Stanislav Chizhov commented on KAFKA-6003: -- OK. Then I will not try reassigning :) . >

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

[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16189014#comment-16189014 ] Stanislav Chizhov commented on KAFKA-6003: -- Aha! Got it. Will try reassigning then. Used to think

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

[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16189012#comment-16189012 ] Apurva Mehta commented on KAFKA-6003: - Actually, [~schizhov], my recommendation will not work. Even

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16188937#comment-16188937 ] Stanislav Chizhov edited comment on KAFKA-6003 at 10/2/17 10:13 PM:

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

[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16188937#comment-16188937 ] Stanislav Chizhov commented on KAFKA-6003: -- thank you, but that replica does not have any data

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

[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16188927#comment-16188927 ] Apurva Mehta commented on KAFKA-6003: - The answer to both your questions is 'yes'. 1. dropping all

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

[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16188924#comment-16188924 ] Stanislav Chizhov commented on KAFKA-6003: -- Thanks [~apurva]! By rebuilding "from scratch" - do

[jira] [Commented] (KAFKA-5758) Reassigning a topic's partitions can adversely impact other topics

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

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

[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16188909#comment-16188909 ] Apurva Mehta commented on KAFKA-6003: - Thanks [~schizhov]. this is indeed a gap in the current logic,

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

[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta reassigned KAFKA-6003: --- Assignee: Apurva Mehta > Replication Fetcher thread for a partition with no data fails to

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

[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16188863#comment-16188863 ] Stanislav Chizhov commented on KAFKA-6003: -- Well in the case we had in staging it was out of

[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:

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

[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16188815#comment-16188815 ] Apurva Mehta commented on KAFKA-6003: - hi [~schizhov], thanks for filing the JIRA and providing those

[jira] [Commented] (KAFKA-5225) StreamsResetter doesn't allow custom Consumer properties

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

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

[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-6003: --- Priority: Blocker (was: Major) > Replication Fetcher thread for a partition with no data fails to

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

[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-6003: --- Fix Version/s: 0.11.0.2 1.0.0 > Replication Fetcher thread for a partition with no

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

[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Chizhov updated KAFKA-6003: - Description: If a partition of a topic with idempotent producer has no data on 1 of the

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

[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Chizhov updated KAFKA-6003: - Description: If a partition of a topic with idempotent producer has no data on 1 of the

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

[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Chizhov updated KAFKA-6003: - Description: If a partition of a topic with idempotent producer has no data on 1 of the

[jira] [Commented] (KAFKA-5889) MetricsTest is flaky

[ https://issues.apache.org/jira/browse/KAFKA-5889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16188721#comment-16188721 ] Ted Yu commented on KAFKA-5889: ---

[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

[jira] [Commented] (KAFKA-5886) Introduce delivery.timeout.ms producer config (KIP-91)

[ https://issues.apache.org/jira/browse/KAFKA-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16188707#comment-16188707 ] Sumant Tambe commented on KAFKA-5886: - The excellent KIP writeup is courtesy [~jkoshy] > Introduce

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

[ https://issues.apache.org/jira/browse/KAFKA-6000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16188651#comment-16188651 ] Bart Vercammen commented on KAFKA-6000: --- Ok, I'll try to collect all client- and server-logs from

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

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

[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] >

[jira] [Commented] (KAFKA-5886) Introduce delivery.timeout.ms producer config (KIP-91)

[ https://issues.apache.org/jira/browse/KAFKA-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16188552#comment-16188552 ] Tommy Becker commented on KAFKA-5886: - [~sutambe] yes that sounds great which is why I was hoping this

[jira] [Assigned] (KAFKA-5972) Flatten SMT does not work with null values

[ https://issues.apache.org/jira/browse/KAFKA-5972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] siva santhalingam reassigned KAFKA-5972: Assignee: siva santhalingam > Flatten SMT does not work with null values >

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

[ https://issues.apache.org/jira/browse/KAFKA-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edvard Poliakov updated KAFKA-6002: --- Description: My colleague and I have been working on a new Transform, that takes a JSON

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

[ https://issues.apache.org/jira/browse/KAFKA-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edvard Poliakov updated KAFKA-6002: --- Description: My colleague and I have been working on a new Transform, that takes a JSON

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

[ https://issues.apache.org/jira/browse/KAFKA-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edvard Poliakov updated KAFKA-6002: --- Description: My colleague and I have been working on a new Transform, that takes a JSON

[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] [Commented] (KAFKA-5896) Kafka Connect task threads never interrupted

[ https://issues.apache.org/jira/browse/KAFKA-5896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16188495#comment-16188495 ] Nick Pillitteri commented on KAFKA-5896: I've addressed the issues pointed out in the PR. Is there

[jira] [Commented] (KAFKA-5989) disableLogging() causes partitions to not be consumed

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

[jira] [Updated] (KAFKA-5989) disableLogging() causes partitions to not be consumed

[ https://issues.apache.org/jira/browse/KAFKA-5989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5989: -- Summary: disableLogging() causes partitions to not be consumed (was: disableLogging() causes an

[jira] [Commented] (KAFKA-5758) Reassigning a topic's partitions can adversely impact other topics

[ https://issues.apache.org/jira/browse/KAFKA-5758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16188465#comment-16188465 ] Jun Rao commented on KAFKA-5758: [~dwvangeest], thanks for the info. I agree that it's better to handle

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

[ https://issues.apache.org/jira/browse/KAFKA-6000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16188408#comment-16188408 ] Matthias J. Sax commented on KAFKA-6000: Thanks for reporting this. Can you maybe share the full

[jira] [Commented] (KAFKA-5938) Oracle jdbc-source-connector with kafka-connect distributed mode will result in http 500 error

[ https://issues.apache.org/jira/browse/KAFKA-5938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16188389#comment-16188389 ] Wolfgang Clemens commented on KAFKA-5938: - After we got some java and tcp dumps and had a look

[jira] [Commented] (KAFKA-5989) disableLogging() causes an initialization loop

[ https://issues.apache.org/jira/browse/KAFKA-5989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16188387#comment-16188387 ] Damian Guy commented on KAFKA-5989: --- Thanks for the example [~thn929] - i've verified that is indeed a

[jira] [Assigned] (KAFKA-5989) disableLogging() causes an initialization loop

[ https://issues.apache.org/jira/browse/KAFKA-5989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-5989: - Assignee: Damian Guy > disableLogging() causes an initialization loop >

[jira] [Commented] (KAFKA-6001) Remove <Bytes, byte[]> from usages of Materialized in Streams

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

[jira] [Created] (KAFKA-6001) Remove <Bytes, byte[]> 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

[jira] [Commented] (KAFKA-5999) Offset Fetch Request

[ https://issues.apache.org/jira/browse/KAFKA-5999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16188332#comment-16188332 ] Vahid Hashemian commented on KAFKA-5999: [~zhaoweilong1023]] Could you please elaborate on the

[jira] [Commented] (KAFKA-5886) Introduce delivery.timeout.ms producer config (KIP-91)

[ https://issues.apache.org/jira/browse/KAFKA-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16188300#comment-16188300 ] Sumant Tambe commented on KAFKA-5886: - [~guozhang] I'm resuming this today. I'll keep you posted.

[jira] [Commented] (KAFKA-5886) Introduce delivery.timeout.ms producer config (KIP-91)

[ https://issues.apache.org/jira/browse/KAFKA-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16188261#comment-16188261 ] Guozhang Wang commented on KAFKA-5886: -- [~becket_qin] [~sutambe] How's things going on this JIRA? Can

[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=16188250#comment-16188250 ] Guozhang Wang commented on KAFKA-2376: -- [~rhauch] There are still a few subtasks for this JIRA, which

[jira] [Commented] (KAFKA-5445) Document exceptions thrown by AdminClient methods

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

[jira] [Commented] (KAFKA-5886) Introduce delivery.timeout.ms producer config (KIP-91)

[ https://issues.apache.org/jira/browse/KAFKA-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16187976#comment-16187976 ] Tommy Becker commented on KAFKA-5886: - Thanks for the response. Though the KIP may be an improvement,

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

[ https://issues.apache.org/jira/browse/KAFKA-6000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bart Vercammen updated KAFKA-6000: -- Description: Potential interop issue between Kafka Streams (0.10.2.1) and Kafka (0.11.0.1)

[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

[jira] [Updated] (KAFKA-5919) Adding checks on "version" field for tools using it

[ https://issues.apache.org/jira/browse/KAFKA-5919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno updated KAFKA-5919: -- Description: Hi, the kafka-delete-records script allows user to pass information about records

[jira] [Updated] (KAFKA-5919) Adding checks on "version" field for tools using it

[ https://issues.apache.org/jira/browse/KAFKA-5919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno updated KAFKA-5919: -- Summary: Adding checks on "version" field for tools using it (was: Adding checks on "version"

[jira] [Commented] (KAFKA-4967) java.io.EOFException Error while committing offsets

[ https://issues.apache.org/jira/browse/KAFKA-4967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16187741#comment-16187741 ] Jorge Machado commented on KAFKA-4967: -- I think this is a mismatch config from kafka broker and kafka

[jira] [Commented] (KAFKA-5972) Flatten SMT does not work with null values

[ https://issues.apache.org/jira/browse/KAFKA-5972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16187687#comment-16187687 ] Tomas Zuklys commented on KAFKA-5972: - Hi Siva, Sure, you can assign it to yourself. > Flatten SMT

[jira] [Commented] (KAFKA-5988) Consider removing StreamThread#STREAM_THREAD_ID_SEQUENCE

[ https://issues.apache.org/jira/browse/KAFKA-5988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16187683#comment-16187683 ] Matthias J. Sax commented on KAFKA-5988: [~sssanthalingam] [~tedyu] Thinking about this, I am not