[jira] [Created] (KAFKA-6410) Scala ReassignPartitionsClusterTest (shouldExecuteThrottledReassignment)

Wladimir Schmidt created KAFKA-6410: --- Summary: Scala ReassignPartitionsClusterTest (shouldExecuteThrottledReassignment) Key: KAFKA-6410 URL: https://issues.apache.org/jira/browse/KAFKA-6410 Project:

[jira] [Created] (KAFKA-6409) LogRecoveryTest (testHWCheckpointWithFailuresSingleLogSegment) is flaky

Wladimir Schmidt created KAFKA-6409: --- Summary: LogRecoveryTest (testHWCheckpointWithFailuresSingleLogSegment) is flaky Key: KAFKA-6409 URL: https://issues.apache.org/jira/browse/KAFKA-6409 Project:

Jenkins build is back to normal : kafka-trunk-jdk8 #2301

See

[jira] [Created] (KAFKA-6408) Kafka MirrorMaker doesn't replicate messages when .* regex is used

Waleed Fateem created KAFKA-6408: Summary: Kafka MirrorMaker doesn't replicate messages when .* regex is used Key: KAFKA-6408 URL: https://issues.apache.org/jira/browse/KAFKA-6408 Project: Kafka

Re: [DISCUSS] KIP-228 Negative record timestamp support

I agree that changing message format or using a flag bit might not be worth it. However, just keeping -1 as "unknown" leaving a time gap give me a lot of headache, too. Your arguments about "not an issue in practice" kinda make sense to me, but I see the number of question on the mailing list alre

Re: [DISCUSS]KIP-216: IQ should throw different exceptions for different errors

Vito, Sorry for this late reply. There can be two cases: - either a store got migrated way and thus, is not hosted an the application instance anymore, - or, a store is hosted but the instance is in state rebalance For the first case, users need to rediscover the store. For the second case, t

Re: [DISCUSS]: KIP-230: Name Windowing Joins

Thanks for updating the KIP. The code-diff is a little hard to read. It's better to so something similar as in this KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-245%3A+Use+Properties+instead+of+StreamsConfig+in+KafkaStreams+constructor (Just as an example. Maybe take a look as othe

[jira] [Created] (KAFKA-6407) Sink task metrics are the same for all connectors

Alexander Koval created KAFKA-6407: -- Summary: Sink task metrics are the same for all connectors Key: KAFKA-6407 URL: https://issues.apache.org/jira/browse/KAFKA-6407 Project: Kafka Issue Typ

Jenkins build is back to normal : kafka-trunk-jdk9 #280

See

[jira] [Created] (KAFKA-6406) Topic deletion fails and kafka shuts down (on windows only)

pre sto created KAFKA-6406: -- Summary: Topic deletion fails and kafka shuts down (on windows only) Key: KAFKA-6406 URL: https://issues.apache.org/jira/browse/KAFKA-6406 Project: Kafka Issue Type: Bu

Re: [DISCUSS] KIP-242: Mask password fields in Kafka Connect REST response

For the last point you raised, can you come up with a unit test that shows what you observed ? Cheers On Mon, Dec 18, 2017 at 11:14 AM, Vincent Meng wrote: > Hi all, > > I've created KIP-242, a proposal to secure credentials in kafka connect > rest endpoint. > > https://cwiki.apache.org/conflue

Re: Unable to start Sink connectors[Confluent Kafka]

Looking at https://docs.confluent.io/3.0.0/control-center/docs/clients.html#adding-the-interceptor-to-your-kafka-consumer , it seems that the class name in interceptor.classes had a typo (extra 'e'). Can you double check ? Cheers On Tue, Dec 19, 2017 at 11:00 PM, Somasundaram Sekar < somasundar.