[jira] [Assigned] (KAFKA-6452) Add documentation for delegation token authentication mechanism

[ https://issues.apache.org/jira/browse/KAFKA-6452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-6452: Assignee: Manikumar Fix Version/s: 1.1.0 Component/s: documentation > Add

[jira] [Assigned] (KAFKA-6312) Add documentation about kafka-consumer-groups.sh's ability to set/change offsets

[ https://issues.apache.org/jira/browse/KAFKA-6312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mayank Tankhiwale reassigned KAFKA-6312: Assignee: Mayank Tankhiwale > Add documentation about kafka-consumer-groups.sh's

[jira] [Commented] (KAFKA-6323) punctuate with WALL_CLOCK_TIME triggered immediately

[ https://issues.apache.org/jira/browse/KAFKA-6323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346143#comment-16346143 ] ASF GitHub Bot commented on KAFKA-6323: --- mjsax closed pull request #4301: KAFKA-6323: punctuate with

[jira] [Updated] (KAFKA-6454) Allow timestamp manipulation in Processor API

[ https://issues.apache.org/jira/browse/KAFKA-6454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6454: --- Labels: kip (was: ) > Allow timestamp manipulation in Processor API >

[jira] [Updated] (KAFKA-6454) Allow timestamp manipulation in Processor API

[ https://issues.apache.org/jira/browse/KAFKA-6454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6454: --- Description: Atm, Kafka Streams only has a defined "contract" about timestamp propagation at

[jira] [Created] (KAFKA-6506) Integration or unit test for Connect REST SSL Support

Ewen Cheslack-Postava created KAFKA-6506: Summary: Integration or unit test for Connect REST SSL Support Key: KAFKA-6506 URL: https://issues.apache.org/jira/browse/KAFKA-6506 Project: Kafka

[jira] [Assigned] (KAFKA-6454) Allow timestamp manipulation in Processor API

[ https://issues.apache.org/jira/browse/KAFKA-6454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6454: -- Assignee: Matthias J. Sax > Allow timestamp manipulation in Processor API >

[jira] [Updated] (KAFKA-6454) Allow timestamp manipulation in Processor API

[ https://issues.apache.org/jira/browse/KAFKA-6454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6454: --- Fix Version/s: 1.2.0 > Allow timestamp manipulation in Processor API >

[jira] [Commented] (KAFKA-3625) Move kafka-streams test fixtures into a published package

[ https://issues.apache.org/jira/browse/KAFKA-3625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346096#comment-16346096 ] ASF GitHub Bot commented on KAFKA-3625: --- mjsax opened a new pull request #4493: KAFKA-3625: add docs

[jira] [Assigned] (KAFKA-6499) Avoid creating dummy checkpoint files with no state stores

[ https://issues.apache.org/jira/browse/KAFKA-6499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-6499: Assignee: Guozhang Wang > Avoid creating dummy checkpoint files with no state stores >

[jira] [Commented] (KAFKA-6499) Avoid creating dummy checkpoint files with no state stores

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

[jira] [Updated] (KAFKA-4930) Connect Rest API allows creating connectors with an empty name - KIP-212

[ https://issues.apache.org/jira/browse/KAFKA-4930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4930: - Summary: Connect Rest API allows creating connectors with an empty name - KIP-212

[jira] [Updated] (KAFKA-4640) Improve Streams unit test coverage

[ https://issues.apache.org/jira/browse/KAFKA-4640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4640: - Description: There are some important methods in streams that are lacking good unit-test

[jira] [Updated] (KAFKA-4651) Improve test coverage of Stores

[ https://issues.apache.org/jira/browse/KAFKA-4651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4651: - Labels: newbie (was: ) > Improve test coverage of Stores > --- > >

[jira] [Updated] (KAFKA-4641) Improve test coverage of StreamsThread

[ https://issues.apache.org/jira/browse/KAFKA-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4641: - Labels: newbie (was: ) > Improve test coverage of StreamsThread >

[jira] [Commented] (KAFKA-5660) Don't throw TopologyBuilderException during runtime

[ https://issues.apache.org/jira/browse/KAFKA-5660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346012#comment-16346012 ] Matthias J. Sax commented on KAFKA-5660: We plan to remove `KStreamBuilder` for 1.2 release

[jira] [Commented] (KAFKA-6018) Make KafkaFuture.Function java 8 lambda compatible

[ https://issues.apache.org/jira/browse/KAFKA-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346010#comment-16346010 ] ASF GitHub Bot commented on KAFKA-6018: --- ewencp closed pull request #4033: KAFKA-6018: Make

[jira] [Resolved] (KAFKA-6018) Make KafkaFuture.Function java 8 lambda compatible

[ https://issues.apache.org/jira/browse/KAFKA-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-6018. -- Resolution: Fixed Fix Version/s: 1.1.0 Issue resolved by pull request

[jira] [Updated] (KAFKA-4650) Improve test coverage org.apache.kafka.streams.kstream.internals

[ https://issues.apache.org/jira/browse/KAFKA-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4650: - Labels: newbie (was: ) > Improve test coverage org.apache.kafka.streams.kstream.internals >

[jira] [Assigned] (KAFKA-4650) Improve test coverage org.apache.kafka.streams.kstream.internals

[ https://issues.apache.org/jira/browse/KAFKA-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-4650: Assignee: (was: Damian Guy) > Improve test coverage

[jira] [Updated] (KAFKA-5660) Don't throw TopologyBuilderException during runtime

[ https://issues.apache.org/jira/browse/KAFKA-5660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5660: - Fix Version/s: 1.0.1 1.1.0 > Don't throw TopologyBuilderException during

[jira] [Commented] (KAFKA-6393) Add tool to view active brokers

[ https://issues.apache.org/jira/browse/KAFKA-6393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345986#comment-16345986 ] Jason Gustafson commented on KAFKA-6393: [~yigene] Sure, but we are moving away from dependence on

[jira] [Updated] (KAFKA-5660) Don't throw TopologyBuilderException during runtime

[ https://issues.apache.org/jira/browse/KAFKA-5660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5660: - Fix Version/s: (was: 1.0.1) (was: 1.1.0) > Don't throw

[jira] [Commented] (KAFKA-4969) State-store workload-aware StreamsPartitionAssignor

[ https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345980#comment-16345980 ] ASF GitHub Bot commented on KAFKA-4969: --- guozhangwang closed pull request #4410: KAFKA-4969: Attempt

[jira] [Resolved] (KAFKA-4029) SSL support for Connect REST API

[ https://issues.apache.org/jira/browse/KAFKA-4029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4029. -- Resolution: Fixed Fix Version/s: 1.1.0 Issue resolved by pull request

[jira] [Updated] (KAFKA-6505) Add simple raw "offset-commit-failures", "offset-commits" and "offset-commit-successes" count metric

[ https://issues.apache.org/jira/browse/KAFKA-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-6505: - Labels: needs-kip (was: ) > Add simple raw "offset-commit-failures", "offset-commits" and >

[jira] [Commented] (KAFKA-5660) Don't throw TopologyBuilderException during runtime

[ https://issues.apache.org/jira/browse/KAFKA-5660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345943#comment-16345943 ] Nick Afshartous commented on KAFKA-5660: One question, in {{KStreamBuilder.java}}, there are some

[jira] [Commented] (KAFKA-6418) AdminClient should handle empty or null topic names better

[ https://issues.apache.org/jira/browse/KAFKA-6418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345941#comment-16345941 ] ASF GitHub Bot commented on KAFKA-6418: --- hachikuji closed pull request #4470: KAFKA-6418:

[jira] [Resolved] (KAFKA-6418) AdminClient should handle empty or null topic names better

[ https://issues.apache.org/jira/browse/KAFKA-6418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6418. Resolution: Fixed Fix Version/s: 1.1.0 > AdminClient should handle empty or null

[jira] [Commented] (KAFKA-6166) Streams configuration requires consumer. and producer. in order to be read

[ https://issues.apache.org/jira/browse/KAFKA-6166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345900#comment-16345900 ] ASF GitHub Bot commented on KAFKA-6166: --- guozhangwang closed pull request #4489: KAFKA-6166: Update

[jira] [Commented] (KAFKA-6452) Add documentation for delegation token authentication mechanism

[ https://issues.apache.org/jira/browse/KAFKA-6452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345678#comment-16345678 ] ASF GitHub Bot commented on KAFKA-6452: --- omkreddy opened a new pull request #4490: KAFKA-6452: Add

[jira] [Commented] (KAFKA-6166) Streams configuration requires consumer. and producer. in order to be read

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

[jira] [Commented] (KAFKA-6166) Streams configuration requires consumer. and producer. in order to be read

[ https://issues.apache.org/jira/browse/KAFKA-6166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345589#comment-16345589 ] Guozhang Wang commented on KAFKA-6166: -- I think it should be considered as a regression: we

[jira] [Commented] (KAFKA-6166) Streams configuration requires consumer. and producer. in order to be read

[ https://issues.apache.org/jira/browse/KAFKA-6166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345577#comment-16345577 ] James Cheng commented on KAFKA-6166: This PR didn't have any docs updates. Should it have, or is the

[jira] [Commented] (KAFKA-6345) NetworkClient.inFlightRequestCount() is not thread safe, causing ConcurrentModificationExceptions when sensors are read

[ https://issues.apache.org/jira/browse/KAFKA-6345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345558#comment-16345558 ] ASF GitHub Bot commented on KAFKA-6345: --- becketqin closed pull request #4460: KAFKA-6345: Keep a

[jira] [Updated] (KAFKA-6492) LogSemgent.truncateTo() should always resize the index file

[ https://issues.apache.org/jira/browse/KAFKA-6492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-6492: Affects Version/s: 1.0.0 Fix Version/s: 1.1.0 Component/s: core >

[jira] [Commented] (KAFKA-6166) Streams configuration requires consumer. and producer. in order to be read

[ https://issues.apache.org/jira/browse/KAFKA-6166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345552#comment-16345552 ] ASF GitHub Bot commented on KAFKA-6166: --- guozhangwang closed pull request #4434: KAFKA-6166: Streams

[jira] [Updated] (KAFKA-6502) Kafka streams deserialization handler not committing offsets on error records

[ https://issues.apache.org/jira/browse/KAFKA-6502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6502: - Component/s: streams > Kafka streams deserialization handler not committing offsets on error

[jira] [Commented] (KAFKA-6497) streams#store ambiguous InvalidStateStoreException

[ https://issues.apache.org/jira/browse/KAFKA-6497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345524#comment-16345524 ] Matthias J. Sax commented on KAFKA-6497: No need to apologize :) Thanks. > streams#store

[jira] [Updated] (KAFKA-6148) ClassCastException in BigQuery connector

[ https://issues.apache.org/jira/browse/KAFKA-6148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-6148: --- Fix Version/s: (was: 1.0.2) 1.0.1 > ClassCastException in BigQuery

[jira] [Commented] (KAFKA-6148) ClassCastException in BigQuery connector

[ https://issues.apache.org/jira/browse/KAFKA-6148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345349#comment-16345349 ] ASF GitHub Bot commented on KAFKA-6148: --- hachikuji closed pull request #4457: KAFKA-6148:

[jira] [Commented] (KAFKA-6246) Enable reconfiguration of listeners and security configs

[ https://issues.apache.org/jira/browse/KAFKA-6246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345255#comment-16345255 ] ASF GitHub Bot commented on KAFKA-6246: --- rajinisivaram opened a new pull request #4488: KAFKA-6246:

[jira] [Comment Edited] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345235#comment-16345235 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5882 at 1/30/18 3:36 PM:

[jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345235#comment-16345235 ] Seweryn Habdank-Wojewodzki commented on KAFKA-5882: --- One more comment when it happens

[jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345209#comment-16345209 ] Seweryn Habdank-Wojewodzki commented on KAFKA-5882: --- At 0.11.0.2 we got that as well:

[jira] [Comment Edited] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345209#comment-16345209 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5882 at 1/30/18 3:21 PM:

[jira] [Updated] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki updated KAFKA-5882: -- Affects Version/s: 0.11.0.1 0.11.0.2 >

[jira] [Updated] (KAFKA-6505) Add simple raw "offset-commit-failures", "offset-commits" and "offset-commit-successes" count metric

[ https://issues.apache.org/jira/browse/KAFKA-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Per Steffensen updated KAFKA-6505: -- Affects Version/s: 1.0.0 Priority: Minor (was: Major) Component/s:

[jira] [Created] (KAFKA-6505) Add simple raw "offset-commit-failures", "offset-commits" and "offset-commit-successes" count metric

Per Steffensen created KAFKA-6505: - Summary: Add simple raw "offset-commit-failures", "offset-commits" and "offset-commit-successes" count metric Key: KAFKA-6505 URL:

[jira] [Created] (KAFKA-6504) Connect: Some per-task-metrics not working

Per Steffensen created KAFKA-6504: - Summary: Connect: Some per-task-metrics not working Key: KAFKA-6504 URL: https://issues.apache.org/jira/browse/KAFKA-6504 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-6464) Base64URL encoding under JRE 1.7 is broken due to incorrect padding assumption

[ https://issues.apache.org/jira/browse/KAFKA-6464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345094#comment-16345094 ] Ron Dagostino commented on KAFKA-6464: -- << Base64URL encoding under JRE 1.7 is broken due to

[jira] [Created] (KAFKA-6503) Connect: Plugin scan is very slow

Per Steffensen created KAFKA-6503: - Summary: Connect: Plugin scan is very slow Key: KAFKA-6503 URL: https://issues.apache.org/jira/browse/KAFKA-6503 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-6490) JSON SerializationException Stops Connect

[ https://issues.apache.org/jira/browse/KAFKA-6490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345031#comment-16345031 ] William R. Speirs commented on KAFKA-6490: -- Seems like a simple fix. I wrapped the inside of the

[jira] [Updated] (KAFKA-6490) JSON SerializationException Stops Connect

[ https://issues.apache.org/jira/browse/KAFKA-6490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] William R. Speirs updated KAFKA-6490: - Attachment: KAFKA-6490_v1.patch > JSON SerializationException Stops Connect >

[jira] [Created] (KAFKA-6502) Kafka streams deserialization handler not committing offsets on error records

Soby Chacko created KAFKA-6502: -- Summary: Kafka streams deserialization handler not committing offsets on error records Key: KAFKA-6502 URL: https://issues.apache.org/jira/browse/KAFKA-6502 Project:

[jira] [Updated] (KAFKA-6501) Add test to verify markPartitionsForTruncation after fetcher thread pool resize

[ https://issues.apache.org/jira/browse/KAFKA-6501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-6501: -- Fix Version/s: 1.1.0 > Add test to verify markPartitionsForTruncation after fetcher thread pool

[jira] [Created] (KAFKA-6501) Add test to verify markPartitionsForTruncation after fetcher thread pool resize

Rajini Sivaram created KAFKA-6501: - Summary: Add test to verify markPartitionsForTruncation after fetcher thread pool resize Key: KAFKA-6501 URL: https://issues.apache.org/jira/browse/KAFKA-6501

[jira] [Commented] (KAFKA-6496) NAT and Kafka

[ https://issues.apache.org/jira/browse/KAFKA-6496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16344888#comment-16344888 ] Ronald van de Kuil commented on KAFKA-6496: --- yes. I can image that other tenants projects - or

[jira] [Commented] (KAFKA-6464) Base64URL encoding under JRE 1.7 is broken due to incorrect padding assumption

[ https://issues.apache.org/jira/browse/KAFKA-6464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16344884#comment-16344884 ] ASF GitHub Bot commented on KAFKA-6464: --- rajinisivaram closed pull request #4455: KAFKA-6464: Fix

[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 ] Viktor Somogyi updated KAFKA-5722: -- Fix Version/s: (was: 1.1.0) 1.2.0 Since the KIP is still on vote, I'll

[jira] [Commented] (KAFKA-5876) IQ should throw different exceptions for different errors

[ https://issues.apache.org/jira/browse/KAFKA-5876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16344789#comment-16344789 ] Pegerto Fernandez commented on KAFKA-5876: -- Hi, In addition to the original comment. When the

[jira] [Commented] (KAFKA-6497) streams#store ambiguous InvalidStateStoreException

[ https://issues.apache.org/jira/browse/KAFKA-6497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16344757#comment-16344757 ] Pegerto Fernandez commented on KAFKA-6497: -- Hello [~mjsax] Yes, it does,  I am sorry for the

[jira] [Resolved] (KAFKA-6497) streams#store ambiguous InvalidStateStoreException

[ https://issues.apache.org/jira/browse/KAFKA-6497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pegerto Fernandez resolved KAFKA-6497. -- Resolution: Duplicate > streams#store ambiguous InvalidStateStoreException >

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16344725#comment-16344725 ] Tim Van Laer commented on KAFKA-5998: - It looks like I ran into the same issue. It doesn't seem to